用pushplus+python監(jiān)控亞馬遜到貨動(dòng)態(tài)推送微信

更新時(shí)間：2021年01月29日 15:16:12 作者：towelie

這篇文章主要介紹了用pushplus+python監(jiān)控亞馬遜到貨動(dòng)態(tài)推送微信的示例，幫助大家利用python搶購(gòu)商品，感興趣的朋友可以了解下

xbox series和ps5發(fā)售以來(lái)，國(guó)內(nèi)黃牛價(jià)格一直居高不下。雖然海外amazon上ps5補(bǔ)貨很少而且基本撐不過(guò)一分鐘，但是xbox series系列明顯要好搶很多。

日亞、德亞的xbox series x/s都可以直郵中國(guó)大陸，所以我們只需要借助腳本，監(jiān)控相關(guān)網(wǎng)頁(yè)的動(dòng)態(tài)，在補(bǔ)貨的第一時(shí)刻通過(guò)微信告知我們，然后迅速人工購(gòu)買即可！

需求：pushplus(需要微信關(guān)注公眾號(hào))、python3

一、pushplus相關(guān)介紹

pushplus提供了免費(fèi)的微信消息推送api,具體內(nèi)容可以參考他的官網(wǎng)：pushplus(推送加)微信推送消息直達(dá) (hxtrip.com)

我們需要用到的東西有，登陸后的個(gè)人Token(用于精準(zhǔn)推送消息)，如圖：

調(diào)用該接口可使用如下代碼，token為上面提到的你個(gè)人的token,titile對(duì)應(yīng)推送標(biāo)題，content對(duì)應(yīng)推送內(nèi)容，此代碼借鑒了官方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)

二、整體思路

不出意外的話，你在編寫代碼時(shí)，amazon應(yīng)該處于無(wú)貨狀態(tài)(有貨直接就買了啊喂)！??！我們?cè)诖藭r(shí)打開(kāi)amazon頁(yè)面，可以看到如下界面：

在新版Edge瀏覽器或者chrome下，按F12查看網(wǎng)頁(yè)源碼，選定中間Currently unavailable標(biāo)識(shí)的區(qū)域(五顆星下面那個(gè)，最好覆蓋范圍大一點(diǎn))，能看到代碼如下：

有一個(gè)比較簡(jiǎn)單的辦法，判斷amazon是否有補(bǔ)貨。我們可以抓取這一部分的html源碼，存進(jìn)一個(gè)文件里(txt即可)。每過(guò)一定時(shí)間，重新抓取源碼，如果這些源碼變化了，那么基本上是網(wǎng)站更新了(補(bǔ)貨了)。不過(guò)有個(gè)小瑕疵，這種補(bǔ)貨也可能是亞馬遜第三方（黃牛）補(bǔ)貨- -

不過(guò)總歸是有了一個(gè)判斷上新的方法嘛；其實(shí)黃牛補(bǔ)貨很少的，德亞上好像看不到黃牛（我個(gè)人沒(méi)見(jiàn)過(guò)德亞上的第三方賣xsx的），日亞上基本沒(méi)有啥黃牛賣xbox

好了，接下來(lái)，我們看看如何實(shí)現(xiàn)相關(guān)功能

三、Requests+BeautifulSoup獲取相關(guān)html源碼

我們使用Requests+BeautfifulSoup來(lái)抓取<div id = 'availability_feature_div> </div>這個(gè)標(biāo)簽內(nèi)部的所有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會(huì)檢測(cè)到爬蟲(chóng)，不會(huì)給你返回完整html代碼。第7行把requests給close掉是因?yàn)椋以诒O(jiān)測(cè)時(shí)開(kāi)了兩個(gè)線程同時(shí)檢測(cè)日亞和德亞，如果不加這一句的話，會(huì)被amazon認(rèn)為是我在攻擊網(wǎng)站，會(huì)拒絕我的網(wǎng)絡(luò)訪問(wèn)

最終的target是被轉(zhuǎn)為str格式的相應(yīng)html源碼，接下來(lái)只需要將其保存到文件，每隔一定時(shí)間再次爬蟲(chóng)比對(duì)就行了

四、完整代碼

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()

本代碼開(kāi)了兩個(gè)線程分別監(jiān)控日亞和德亞的xsx，detect_url是日亞鏈接，url_germany是德亞鏈接；

注意：德亞能夠直接上，日亞如果你上不去自己想辦法(不能說(shuō)的東西，你懂的)

里面OriginFile和NewFile的文件名可以隨意命名，OriginFile指的是之前爬蟲(chóng)的html，NewFile是新的爬蟲(chóng)html，如果內(nèi)容不一樣，就會(huì)收到微信消息推送啦

這個(gè)圖只是測(cè)試用的，這個(gè)時(shí)刻日亞也沒(méi)有真的補(bǔ)貨哈哈哈

以上就是用pushplus+python監(jiān)控亞馬遜到貨動(dòng)態(tài)推送微信的詳細(xì)內(nèi)容，更多關(guān)于pushplus+python監(jiān)控亞馬遜到貨動(dòng)態(tài)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: