douyin API update

douyin API update

Author: Jack-Cherish

douyin_pro_2.py

@@ -1,20 +1,26 @@
 # -*- coding:utf-8 -*-
 from contextlib import closing
-import requests, json, re, os, sys
-from datetime import datetime, timezone
+import requests, json, re, os, sys, random
+from ipaddress import ip_address
+from subprocess import Popen, PIPE
 
 class DouYin(object):
 def __init__(self, width = 500, height = 300):
 """
 抖音App视频下载
 """
+rip = ip_address('.'.join(map(str, (random.randint(0, 255) for _ in range(4)))))
+while rip.is_private:
+rip = ip_address('.'.join(map(str, (random.randint(0, 255) for _ in range(4)))))
 self.headers = {
 'accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8',
 'accept-encoding': 'gzip, deflate, br',
 'accept-language': 'zh-CN,zh;q=0.9',
 'cache-control': 'max-age=0',
 'upgrade-insecure-requests': '1',
 'user-agent': 'Mozilla/5.0 (Linux; U; Android 5.1.1; zh-cn; MI 4S Build/LMY47V) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/53.0.2785.146 Mobile Safari/537.36 XiaoMi/MiuiBrowser/9.1.3',
+'X-Real-IP': str(rip),
+'X-Forwarded-For': str(rip),
 }
 
 def get_video_urls(self, user_id):
@@ -31,30 +37,45 @@ def get_video_urls(self, user_id):
 video_urls = []
 share_urls = []
 unique_id = ''
-while unique_id != user_id:
-search_url = 'https://api.amemv.com/aweme/v1/discover/search/?cursor=0&keyword=%s&count=10&type=1&retry_type=no_retry&iid=17900846586&device_id=34692364855&ac=wifi&channel=xiaomi&aid=1128&app_name=aweme&version_code=162&version_name=1.6.2&device_platform=android&ssmix=a&device_type=MI+5&device_brand=Xiaomi&os_api=24&os_version=7.0&uuid=861945034132187&openudid=dc451556fc0eeadb&manifest_version_code=162&resolution=1080*1920&dpi=480&update_version_code=1622' % user_id
-req = requests.get(search_url, headers=self.headers)
-html = json.loads(req.text)
-aweme_count = 32767 # html['user_list'][0]['user_info']['aweme_count']
-uid = html['user_list'][0]['user_info']['uid']
-nickname = html['user_list'][0]['user_info']['nickname']
-unique_id = html['user_list'][0]['user_info']['unique_id']
-user_url = 'https://www.amemv.com/aweme/v1/aweme/post/?user_id=%s&max_cursor=0&count=%s' % (uid, aweme_count)
+device_id = str(random.randint(3, 5)) + ''.join(map(str, (random.randint(0, 9) for _ in range(10))))
+search_url = 'https://api.amemv.com/aweme/v1/discover/search/?cursor=0&keyword={0}&count=10&type=1&retry_type=no_retry&device_id={1}&ac=wifi&channel=xiaomi&aid=1128&app_name=aweme&version_code=162&version_name=1.6.2&device_platform=android&ssmix=a&device_type=MI+5&device_brand=Xiaomi&os_api=24&os_version=7.0&manifest_version_code=162&resolution=1080*1920&dpi=480&update_version_code=1622'.format(user_id, device_id)
+req = requests.get(search_url, headers=self.headers)
+html = json.loads(req.text)
+aweme_count = 32767 # html['user_list'][0]['user_info']['aweme_count']
+uid = html['user_list'][0]['user_info']['uid']
+nickname = html['user_list'][0]['user_info']['nickname']
+unique_id = html['user_list'][0]['user_info']['unique_id']
+if unique_id != user_id:
+unique_id = html['user_list'][0]['user_info']['short_id']
+if unique_id != user_id:
+print('用户ID可能输入错误或无法搜索到此用户ID')
+sys.exit()
+share_user_url = 'https://www.amemv.com/share/user/%s' % uid
+share_user = requests.get(share_user_url, headers=self.headers)
+_dytk_re = re.compile(r"dytk: '(.+)'")
+dytk = _dytk_re.search(share_user.text).group(1)
+print('签名JS下载中')
+self.video_downloader('https://raw.githubusercontent.com/loadchange/amemv-crawler/master/fuck-byted-acrawler.js', 'fuck-byted-acrawler.js')
+try:
+process = Popen(['node', 'fuck-byted-acrawler.js', str(uid)], stdout=PIPE, stderr=PIPE)
+except (OSError, IOError) as err:
+print('请先安装 node.js: https://nodejs.org/')
+sys.exit()
+sign = process.communicate()[0].decode()
+user_url = 'https://www.amemv.com/aweme/v1/aweme/post/?user_id=%s&max_cursor=0&count=%s&aid=1128&_signature=%s&dytk=%s' % (uid, aweme_count, sign, dytk)
 req = requests.get(user_url, headers=self.headers)
 html = json.loads(req.text)
 for each in html['aweme_list']:
 share_desc = each['share_info']['share_desc']
 if os.name == 'nt':
 for c in r'\/:*?"<>|':
-share_desc = share_desc.replace(c, '')
-unix_timestamp = each['create_time']
-utc_time = datetime.fromtimestamp(unix_timestamp, timezone.utc)
-local_time = utc_time.astimezone()
-tc = local_time.strftime('%Y-%m-%d-%H-%M-%S')
+nickname = nickname.replace(c, '').strip()
+share_desc = share_desc.replace(c, '').strip()
+share_id = each['aweme_id']
 if share_desc in ['抖音-原创音乐短视频社区', 'TikTok']:
-video_names.append(tc + '.mp4')
+video_names.append(share_id + '.mp4')
 else:
-video_names.append(tc + '-' + share_desc + '.mp4')
+video_names.append(share_id + '-' + share_desc + '.mp4')
 share_urls.append(each['share_info']['share_url'])
 video_urls.append(each['video']['play_addr']['url_list'][0])