91批量 python源代码，正常跑没问题，其他功能你们自由发挥

  • A+
所属分类：软件应用教程

代码是有代码基础的人的，
没有代码基础的，可以用百度网盘里的程序去跑，
https://pan.baidu.com/s/1huEU-EVjzn-daNBfbIkX6w 密码：hjco

  1. # coding=gbk
  3. from multiprocessing import Pool
  4. import time
  5. import re
  6. import multiprocessing
  7. from bs4 import BeautifulSoup
  8. import  requests
  9. from xlrd import open_workbook
  10. from xlutils.copy import copy
  11. print(\"程序开始执行 by cl monkey13180\")
  12. try:
  13.     f = open('config.txt', 'r')
  14.     config = str(f.read()).split('\n')
  15.     start = config[0]
  16.     end = config[1]
  17.     url = config[2]
  18. except Exception as e:
  19.     print(\"请在当前目录下创建config.txt, 请按顺序填写页码,fid,域名并敲回车!\")
  21. class Pool_91(object):
  22.     def __init__(self,range,res):
  23.         self.range=range
  24.         self.res=res
  25.     def run(self):
  26.         # print(self.res)
  27.         AllData = []
  28.         for x in range(self.range[0], self.range[1]):
  29.             proxy_list = []
  30.             true_url = self.getTrueUrl(x)
  31.             proxy_list.append(true_url)
  32.             proxy_list.append(self.res[x][1])
  33.             AllData.append(proxy_list)
  34.         # print(AllData)
  35.         return AllData
  36.     def getTrueUrl(self,num):
  38.         print('正在保存：{}{}'.format(self.res[num][1],self.res[num][0]))
  39.         try:
  40.             data = {
  41.                 'url': self.res[num][0]
  42.             }
  43.             aaa = requests.post('http://cj.9530.net/index.php', data=data, allow_redirects=False)
  44.             soup = BeautifulSoup(aaa.content, 'lxml')
  45.             aa = (soup.find_all(attrs={'download': 'a'}))
  46.             true_url =(aa[0].get('href'))
  47.         except:
  48.             pass
  49.         return true_url
  50.     def mycallback(self,x):
  53.         rexcel = open_workbook(\"list.xls\")
  54.         rows = rexcel.sheets()[0].nrows
  55.         excel = copy(rexcel)
  56.         table = excel.get_sheet(0)
  57.         #
  58.         row = rows
  59.         for value in x:
  60.             table.write(row, 0, time.strftime(\"%Y-%m-%d %H:%M:%S\"))
  61.             table.write(row, 1, value[1])
  62.             table.write(row, 2, value[0])
  63.             row += 1
  64.         excel.save(\"list.xls\")
  68. if __name__ == '__main__':
  69.     multiprocessing.freeze_support()
  70.     AllUrl = []
  71.     for i in range(int(start), int(end)+1):  # 1-6
  72.         time.sleep(2)
  73.         data={
  74.             'session_language':'cn_CN'
  75.         }
  76.         page = requests.post('{}&page={}'.format(url,i),data)
  77.         soup = BeautifulSoup(page.content, 'html.parser')
  78.         TempUrlList = soup.find_all(href=re.compile('view_video'),title='')
  79.         TempUrlList1 = soup.find_all(class_='listchannel')
  80.         for i in TempUrlList:
  81.             UrlList = []
  82.             UrlList.append(i['href'])
  83.             UrlList.append(i.findAll('img')[0]['title'])
  84.             AllUrl.append((UrlList))
  86.     all_num = len(AllUrl)
  87.     num = 4  # number of cpu cores
  88.     per_num, left = divmod(all_num, num)
  89.     s = range(0, all_num, per_num)
  90.     res = []
  91.     for i in range(len(s) - 1):
  92.         res.append((s[i], s[i + 1]))
  93.     res.append((s[len(s) - 1], all_num))
  94.     pool = Pool()
  95.     for i in res:
  96.         _91pron = Pool_91(i,AllUrl)
  98.         pool.apply_async(_91pron.run, (), callback=_91pron.mycallback)
  100.     pool.close()
  101.     pool.join()

环境python3.6
写的不好请见谅，早上更新了下程序，怕大家看不到，就新开了个帖子.

1 2 3