强制要求输入机器号
This commit is contained in:
parent
274f0ac664
commit
1c2b697a3c
11
oneget.py
11
oneget.py
@ -57,8 +57,10 @@ class RetryRequests:
|
|||||||
kwargs.setdefault("proxies", self.proxies)
|
kwargs.setdefault("proxies", self.proxies)
|
||||||
return self.session.post(url, **kwargs)
|
return self.session.post(url, **kwargs)
|
||||||
|
|
||||||
|
|
||||||
req = RetryRequests()
|
req = RetryRequests()
|
||||||
|
|
||||||
|
|
||||||
def clean_dash_to_zero(val):
|
def clean_dash_to_zero(val):
|
||||||
if val in ('-', '', None):
|
if val in ('-', '', None):
|
||||||
return 0
|
return 0
|
||||||
@ -227,6 +229,7 @@ class DMVideoInfo:
|
|||||||
print(f"[ERROR] 请求失败 vxid={v_xid} : {e}")
|
print(f"[ERROR] 请求失败 vxid={v_xid} : {e}")
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
||||||
def parse_args() -> argparse.Namespace:
|
def parse_args() -> argparse.Namespace:
|
||||||
global MACHINE_ID
|
global MACHINE_ID
|
||||||
parser = argparse.ArgumentParser(
|
parser = argparse.ArgumentParser(
|
||||||
@ -247,6 +250,7 @@ def parse_args() -> argparse.Namespace:
|
|||||||
raise ValueError("请指定机器编号")
|
raise ValueError("请指定机器编号")
|
||||||
return args
|
return args
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
kwdata = db.get_web_items()
|
kwdata = db.get_web_items()
|
||||||
if not kwdata:
|
if not kwdata:
|
||||||
@ -637,7 +641,7 @@ def main():
|
|||||||
payload = json.dumps(data).encode()
|
payload = json.dumps(data).encode()
|
||||||
|
|
||||||
response = req.post('https://graphql.api.dailymotion.com/', headers=headers, data=payload,
|
response = req.post('https://graphql.api.dailymotion.com/', headers=headers, data=payload,
|
||||||
proxies=proxies)
|
proxies=proxies)
|
||||||
|
|
||||||
data = response.json()
|
data = response.json()
|
||||||
edges = data['data']['search']['stories']['edges']
|
edges = data['data']['search']['stories']['edges']
|
||||||
@ -661,11 +665,14 @@ def main():
|
|||||||
executor.map(dmvideo_info.get_video_info, tancks)
|
executor.map(dmvideo_info.get_video_info, tancks)
|
||||||
if edges_len < 20:
|
if edges_len < 20:
|
||||||
break
|
break
|
||||||
|
|
||||||
|
|
||||||
def run():
|
def run():
|
||||||
parse_args()
|
parse_args()
|
||||||
while True:
|
while True:
|
||||||
main()
|
main()
|
||||||
time.sleep(60)
|
time.sleep(60)
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user