Python-定时爬取指定城市天气(一)-发送给关心的微信好友

 1 headers = {
 2         "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/69.0.3497.100 Safari/537.36",
 3     }
 4 
 5 def getWeath(city_code):
 6     try:
 7         url = f‘http://www.weather.com.cn/weather/{city_code}.shtml‘
 8         resp = requests.get(url, headers = headers)
 9     except BaseException as e:
10         print(e)
11         return {}
12 
13     resp.encoding = ‘utf-8‘
14     soup = BeautifulSoup(resp.text, ‘html.parser‘)
15     tagToday = soup.find(‘p‘, class_ = "tem")  #第一个包含class="tem"的p标签即为存放今天天气数据的标签
16     try:
17         temperatureHigh = tagToday.span.string  #有时候这个最高温度是不显示的，此时利用第二天的最高温度代替。
18     except AttributeError:
19         temperatureHigh = tagToday.find_next(‘p‘, class_="tem").span.string  #获取第二天的最高温度代替
20 
21     temperatureLow = tagToday.i.string  #获取最低温度
22     weather = soup.find(‘p‘, class_ = "wea").string #获取天气
23     wind = soup.find(‘p‘, class_ = "win") #获取风力
24     clothes = soup.find(‘li‘, class_ = "li3 hot") #穿衣指数
25 
26     return {‘温度‘:f‘{temperatureHigh}/{temperatureLow}‘
27     , ‘天气‘:weather
28     , ‘风力‘:wind.i.string
29     , ‘穿衣‘:clothes.a.span.string + ‘,‘ + clothes.a.p.string}

1 def strDic(dic):
2     str_weather = ‘‘
3     for key in dic:
4        str_weather += key + ‘:‘ + dic[key]
5        str_weather += ‘\n‘
6     return str_weather

 1 def sendWeatherMsg(receivers, msg):
 2     try:
 3         #receivers = [u‘拉卡拉‘, u‘证明给他看‘, u‘李静‘]
 4         
 5         #receivers = u‘李静,情绕指尖‘
 6          
 7         ‘‘‘ 
 8         #发送给指定好友 如果好友不存在 则发送给文件夹传输助手
 9         Sender(receivers = u‘证明给他看‘).send(msg)
10         Sender(receivers = u‘拉卡拉‘).send(msg)
11         Sender(receivers = u‘李静‘).send(msg)
12         ‘‘‘
13 
14         ‘‘‘   ‘‘‘
15         #发送给指定接收的用户  
16         #receivers = u‘拉卡拉‘
17         #接受者必须是监听对象的子集
18         sender = Sender(receivers = receivers, token = ‘weather_report_123456789‘)
19         sender.send(msg)#如果没有指定receivers则发送给文件传输助手
20         
21 
22         ‘‘‘ 
23         receivers = u‘李静,情绕指尖‘
24         sender = Sender(receivers = receivers, token = ‘weather_report_123456789‘)
25        
26         #有时候好使    有时候不好使
27         sender.send_to(‘@wss‘, u‘拉卡拉‘) #消息发送失败 会默认发送给receivers的第一个用户 Sender和Listen
28         #sender.send_to(msg, u‘证明给他看‘)
29         ‘‘‘
30 
31         #测试控制命令
32         ‘‘‘
33         receivers = u‘拉卡拉‘
34         sender = Sender(receivers = receivers, token = ‘weather_report_123456789‘)
35         sender.send(‘@wss‘)#文如果没有指定receivers则发送给文件传输助手件传输助手
36         ‘‘‘
37 
38     except BaseException as e:
39         print(e)

 1 bot = Bot(cache_path = True)
 2 
 3 receivers = []
 4 receivers.append(bot.file_helper)
 5 receivers.append(bot.friends().search(‘拉卡拉‘)[0])
 6 receivers.append(ensure_one(bot.friends().search(‘李静‘, city=‘西安‘)))#有可能搜索出多个结果
 7 receivers.append(bot.friends().search(‘证明给他看‘)[0])
 8 receivers.append(bot.friends().search(‘妈‘)[0])
 9 
10 print(receivers)
11 
12 listen(bot, receivers = receivers, token = ‘weather_report_123456789‘) #关键一步

 1 import os
 2 
 3 class City(object):
 4     def __init__(self):
 5         self.city = {}
 6 
 7     def load(self, file):
 8         if os.path.exists(file):
 9             with open(file, ‘r‘, encoding = ‘utf-8‘) as f:
10                 cityInfo = f.readline().strip(‘\n‘)
11                 while cityInfo:
12                     datas = cityInfo.split(‘:‘)
13                     self.city[datas[0]] = datas[1]
14                     cityInfo = f.readline().strip(‘\n‘)
15 
16     def find_code(self, city_name):#根据城市名称，查找城市吧编码
17         if city_name in self.city:
18             return self.city[city_name]
19         return ‘‘

 1 class MyJob(object):
 2     def __sendWeatherMsg(self):
 3         for my_job in self.my_jobs:
 4             code = city_code.find_code(my_job[‘city‘])
 5             wea = getWeath(code)
 6             strWea = strDic(wea)
 7             title = ‘{}天气预报：\n‘.format(my_job[‘city‘])
 8             sendWeatherMsg(my_job[‘receivers‘], title + strWea)#发送天气信息给文件助手
 9 
10     def addMyJobs(self, json_job):
11         self.my_jobs = json_job[‘items‘]
12         scheduler = BackgroundScheduler()
13         scheduler.add_job(self.__sendWeatherMsg, trigger = ‘cron‘, hour = json_job[‘hour‘]
14         , minute = json_job[‘minute‘], second = ‘5,10,15,20,25,30,35,40,45,50,55‘)
15         scheduler.start()

 1 my_jobs = {
 2     "id":"my_jobs",
 3     "hour":"6, 17",
 4     "minute":"30",
 5     "items":[{
 6     "receivers":"文件传输助手,李静,拉卡拉",
 7     "city":"昌平"
 8     },{
 9     "receivers":"文件传输助手,李静,拉卡拉",
10     "city":"海淀"
11     }]
12 }

 1 city_code = city_code.City()
 2 city_code.load(‘city_code.txt‘) 
 3 
 4 if __name__ == "__main__":
 5     try:
 6         ‘‘‘ ‘‘‘
 7         my_job = MyJob()
 8         my_job.addMyJobs(test_jobs)
 9 
10         f = lambda x : lambda y : x+y
11         t = Timer.Timer(f, 24 * 60 * 60)#创建线程 一天给自己发一条消息
12         t.setDaemon(True)
13         t.start()
14         t.join()  #防止主主线程退出
15         
16         #SendWeatherMsg(my_msg)
17 
18     except ResponseError as e:
19         print(e.err_code, e.err_msg) # 查看错误号和错误消息