用pushplus+python监控亚马逊到货动态推送微信

作者:towelie 时间:2022-02-12 16:34:11 

xbox series和ps5发售以来,国内黄牛价格一直居高不下。虽然海外amazon上ps5补货很少而且基本撑不过一分钟,但是xbox series系列明显要好抢很多。

日亚、德亚的xbox series x/s都可以直邮中国大陆,所以我们只需要借助脚本,监控相关网页的动态,在补货的第一时刻通过微信告知我们,然后迅速人工购买即可!

需求:pushplus(需要微信关注公众号)、python3

一、pushplus相关介绍

pushplus提供了免费的微信消息推送api,具体内容可以参考他的官网:pushplus(推送加)微信推送消息直达 (hxtrip.com)

我们需要用到的东西有,登陆后的个人Token(用于精准推送消息),如图:

用pushplus+python监控亚马逊到货动态推送微信

调用该接口可使用如下代码,token为上面提到的你个人的token,titile对应推送标题,content对应推送内容,此代码借鉴了官方demo


def post_push(token, title, content):
url = 'http://pushplus.hxtrip.com/send'
data = {
 "token": token,
 "title": title,
 "content": content
}
body = json.dumps(data).encode(encoding='utf-8')
headers = {'Content-Type': 'application/json'}
requests.post(url, data=body, headers=headers)

二、整体思路

不出意外的话,你在编写代码时,amazon应该处于无货状态(有货直接就买了啊喂)!!!我们在此时打开amazon页面,可以看到如下界面:

用pushplus+python监控亚马逊到货动态推送微信

在新版Edge浏览器或者chrome下,按F12查看网页源码,选定中间Currently unavailable标识的区域(五颗星下面那个,最好覆盖范围大一点),能看到代码如下:

用pushplus+python监控亚马逊到货动态推送微信

有一个比较简单的办法,判断amazon是否有补货。我们可以抓取这一部分的html源码,存进一个文件里(txt即可)。每过一定时间,重新抓取源码,如果这些源码变化了,那么基本上是网站更新了(补货了)。不过有个小瑕疵,这种补货也可能是亚马逊第三方(黄牛)补货-  -

不过总归是有了一个判断上新的方法嘛;其实黄牛补货很少的,德亚上好像看不到黄牛(我个人没见过德亚上的第三方卖xsx的),日亚上基本没有啥黄牛卖xbox

好了,接下来,我们看看如何实现相关功能

三、Requests+BeautifulSoup获取相关html源码

我们使用Requests+BeautfifulSoup来抓取<div id = 'availability_feature_div>  </div>这个标签内部的所有html源码


headers = {
  "User-Agent": "Mozilla/5.0 (Linux; Android 9; SM-A102U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/79.0.3945.93 Mobile Safari/537.36",
  'Content-Type': 'application/json'
 }
html = requests.get(url=self.url, headers=headers)
soup = BeautifulSoup(html.text, 'lxml')
html.close()
target = str(soup.find('div', id='availability_feature_div'))

注意如果不加headers的话,amazon会检测到爬虫,不会给你返回完整html代码。第7行把requests给close掉是因为,我在监测时开了两个线程同时检测日亚和德亚,如果不加这一句的话,会被amazon认为是我在攻击网站,会拒绝我的网络访问

最终的target是被转为str格式的相应html源码,接下来只需要将其保存到文件,每隔一定时间再次爬虫比对就行了

 四、完整代码


import json
import requests
from bs4 import BeautifulSoup
import filecmp
import time
import threading

class listenThread(threading.Thread):
def __init__(self, url, originFile, newFile, content):
 threading.Thread.__init__(self)
 self.url = url
 self.originFile = originFile
 self.newFile = newFile
 self.content = content

def listen(self):
 headers = {
  "User-Agent": "Mozilla/5.0 (Linux; Android 9; SM-A102U) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/79.0.3945.93 Mobile Safari/537.36",
  'Content-Type': 'application/json'
 }
 html = requests.get(url=self.url, headers=headers)
 soup = BeautifulSoup(html.text, 'lxml')
 html.close()
 target = str(soup.find('div', id='availability_feature_div'))
 filetxt = open(self.originFile, 'w', encoding='utf-8')
 filetxt.write(target)
 filetxt.close()
 while True:
  target = str(soup.find('div', id='availability_feature_div'))
  filetxt = open(self.newFile, 'w', encoding='utf-8')
  filetxt.write(target)
  filetxt.close()
  if filecmp.cmp(self.originFile, self.newFile) == False:
   post_push('这里输你自己的token', 'xbox update', self.content)
   fileAvail = open(self.originFile, 'w')
   fileAvail.write(target)
   fileAvail.close()
  time.sleep(30)
def run(self):
 self.listen()

def post_push(token, title, content):
url = 'http://pushplus.hxtrip.com/send'
data = {
 "token": token,
 "title": title,
 "content": content
}
body = json.dumps(data).encode(encoding='utf-8')
headers = {'Content-Type': 'application/json'}
requests.post(url, data=body, headers=headers)

if __name__ == '__main__':
detect_url = 'https://www.amazon.co.jp/-/en/dp/B08GGKZ34Z/ref=sr_1_2?dchild=1&keywords=xbox&qid=1611674118&sr=8-2'
#url_special = 'https://www.amazon.co.jp/-/en/dp/B08GG17K5G/ref=sr_1_6?dchild=1&keywords=xbox%E3%82%B7%E3%83%AA%E3%83%BC%E3%82%BAx&qid=1611722050&sr=8-6'
url_germany = 'https://www.amazon.de/Microsoft-RRT-00009-Xbox-Series-1TB/dp/B08H93ZRLL/ref=sr_1_2?__mk_de_DE=%C3%85M%C3%85%C5%BD%C3%95%C3%91&dchild=1&keywords=xbox&qid=1611742161&sr=8-2'
xbox = listenThread(url=detect_url,originFile='avail.txt',newFile='avail_now.txt',content='日亚')
#xbox_sp = listenThread(url=detect_url,originFile='avail_sp.txt',newFile='avail_now_sp.txt')
xbox_germany = listenThread(url=url_germany,originFile='avail_sp.txt',newFile='avail_now_sp.txt',content='德亚')
xbox.start()
#xbox_sp.start()
xbox_germany.start()

本代码开了两个线程分别监控日亚和德亚的xsx,detect_url是日亚链接,url_germany是德亚链接;

注意:德亚能够直接上,日亚如果你上不去自己想办法(不能说的东西,你懂的)

里面OriginFile和NewFile的文件名可以随意命名,OriginFile指的是之前爬虫的html,NewFile是新的爬虫html,如果内容不一样,就会收到微信消息推送啦

用pushplus+python监控亚马逊到货动态推送微信

这个图只是测试用的,这个时刻日亚也没有真的补货哈哈哈

来源:https://www.cnblogs.com/feiyue666/p/14336870.html

标签:pushplus,python,监控,亚马逊
0
投稿

猜你喜欢

  • Go slice切片使用示例详解

    2023-07-09 12:07:02
  • Python正则表达式的应用详解

    2023-07-29 21:58:51
  • Python数据可视化之matplotlib.pyplot绘图的基本参数详解

    2022-06-10 12:19:48
  • 查看Python依赖包及其版本号信息的方法

    2021-10-13 23:52:59
  • 彻底解决MySql在UTF8字符集下乱码问题

    2011-06-02 12:02:00
  • go语言实现简易比特币系统钱包的原理解析

    2024-05-22 10:12:02
  • python执行CMD指令,并获取返回的方法

    2021-10-19 02:52:40
  • Go-ethereum 解析ethersjs中产生的签名信息思路详解

    2023-08-05 21:34:49
  • python turtle库画圣诞树详细代码教程

    2022-09-20 10:29:33
  • Docker 下MySQL数据库的备份和恢复的操作方法

    2024-01-18 03:02:44
  • 发一个数字拼图网页游戏

    2008-10-12 10:02:00
  • Python实现方便使用的级联进度信息实例

    2021-04-22 12:31:18
  • python实现堆和索引堆的代码示例

    2021-09-21 21:42:05
  • Selenium 模拟浏览器动态加载页面的实现方法

    2023-06-04 11:06:54
  • Go语言context上下文管理的使用

    2023-06-16 03:55:26
  • 使用Pandas的Series方法绘制图像教程

    2023-12-12 17:52:25
  • python 基于opencv操作摄像头

    2023-03-06 08:02:31
  • 详解mysql中的存储引擎

    2024-01-27 05:53:15
  • 深入浅析python with语句简介

    2022-06-30 20:23:16
  • .Net行为型设计模式之访问者模式(Visitor)

    2024-05-13 09:18:14
  • asp之家 网络编程 m.aspxhome.com