先看下效果圖：

用到的模塊：

PyMySQL requests threading wxpy

要實(shí)現(xiàn)上面的示例，首先是有兩大塊地方

獲取天氣信息 通過微信將天氣信息發(fā)送出去

而獲取天氣信息又包括幾個(gè)小的需要注意的地方

獲取天氣信息

獲取天氣信息的接口 獲取天氣信息的城市 獲取所在城市的城市碼

假如我們給多個(gè)人發(fā)送天氣情況，這幾個(gè)人來自不同的城市，那么我們不可能每次都要輸入城市名，然后查找城市碼，然后再訪問接口，獲取天氣情況，這樣會(huì)非常的麻煩，所以我們需要考慮將城市名跟城市碼一一對(duì)應(yīng)起來，說到一一對(duì)應(yīng)，首先想到的數(shù)據(jù)結(jié)構(gòu)便是字典，所以我們可以將這些信息存入一個(gè)字典里，然后持久化到一個(gè)文件中，這樣便方便很多

首先我們獲取最新的 city 表，這個(gè)表是一個(gè) list 類型，大體格式如下：

[ { 'id': 1, 'pid': 0, 'city_code': '101010100', 'city_name': '北京', 'post_code': '100000', 'area_code': '010', 'ctime': '2019-07-11 17:30:06' }, { 'id': 2, 'pid': 0, 'city_code': '', 'city_name': '安徽', 'post_code': null, 'area_code': null, 'ctime': null }]

我們就簡(jiǎn)單的粘貼復(fù)制，放到一個(gè)空的列表中，如下所示，將所有的城市信息放到列表 citycode 中

citycode = [ { 'id': 1, 'pid': 0, 'city_code': '101010100', 'city_name': '北京', 'post_code': '100000', 'area_code': '010', 'ctime': '2019-07-11 17:30:06' },.................. { 'id': 2, 'pid': 0, 'city_code': 'None', 'city_name': '安徽', 'post_code': 'null', 'area_code': 'null', 'ctime': 'null' }]cityinfo = {}#將城市名和城市代碼寫入json文件中with open(’city_for_code.json’,’w’,encoding=’utf-8’) as f: for i in citycode: name = i['city_name'] code = i['city_code'] cityinfo[name] = code f.write(str(cityinfo))#測(cè)試是否能讀取with open(’city_for_code.json’,’r+’,encoding=’utf-8’) as file: data_dst = file.readlines() d = eval(data_dst[0])

然后就是一頓處理，只把我們所需的 city_name 和 city_code 這倆字段取出即可，隨后寫入文件中。如果讀取的話就按照上面方法去讀取，需要注意的是，使用 open()方法讀取文件，得到的內(nèi)容是一個(gè)列表，我們需要通過 eval()方法轉(zhuǎn)化成 dict 類型。

這是把 city_name 和 city_code 放到一個(gè)文件中的方法，另外我們也可以放到數(shù)據(jù)庫(kù)中，這里以 MySQL 為例，安裝 PyMySQL 模塊

import pymysqldb_parames = { ’host’: ’localhost’, ’user’: ’root’, ’password’: ’123456’, ’database’: ’city_code_info’}#連接數(shù)據(jù)庫(kù)conn = pymysql.connect(**db_parames)#創(chuàng)建游標(biāo)對(duì)象，增刪改查都在游標(biāo)上進(jìn)行cursor = conn.cursor()#表存在，就刪除cursor.execute('DROP TABLE IF EXISTS city_code')#建表語句create_table_sql = '''CREATE TABLE `city_code` ( `city_name` varchar(20) DEFAULT NULL, `city_code` varchar(25) DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;'''#建表cursor.execute(create_table_sql)#插入數(shù)據(jù)with open(’city_for_code.json’,’r+’,encoding=’utf-8’) as f: origin_data = f.readlines() current_data = eval(origin_data[0]) #讀取的內(nèi)容是一個(gè)列表，且只包含一個(gè)元素 #print(current_data.get(’北京’,’Not Exists.’)) for name, code in current_data.items(): sql = '''INSERT INTO city_code(city_name, city_code) VALUES (’%s’, ’%s’)''' % (name, code) try: cursor.execute(sql) except: conn.rollback() conn.commit() conn.close()

執(zhí)行這個(gè) python 程序就可以將文件中的城市名跟城市碼存到庫(kù)中，當(dāng)然我們也可以直接獲取到城市名和城市碼，然后跳過文件持久化這一步，直接把這兩個(gè)字段取出存進(jìn)去，但是考慮著代碼要多練多寫，就多此一舉了一下。

下面是輸入城市名就能得到城市碼的代碼塊：

import pymysqldef get_city_code(city_name): db_parames = { ’host’: ’localhost’, ’user’: ’root’, ’password’: ’123456’, ’database’: ’city_code_info’ } #連接數(shù)據(jù)庫(kù) conn = pymysql.connect(**db_parames) #創(chuàng)建游標(biāo)對(duì)象，增刪改查都在游標(biāo)上進(jìn)行 cursor = conn.cursor() #創(chuàng)建查詢語句 select_sql = 'SELECT * FROM city_code where city_name=’%s’'%(city_name) try: cursor.execute(select_sql) result = cursor.fetchall() for row in result: city_code = row[1] return city_code except: return 'Error: unable fetch data!'

然后是根據(jù)輸入的城市碼來獲取天氣情況：

import requestsdef get_weather(city_name,get_date_time=3): city_code = get_city_code(city_name) url = ’http://t.weather.sojson.com/api/weather/city/%s’%(city_code) header = { ’user-agent’: ’Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36’ } response = requests.get(url,header) response.encoding = ’utf-8’ weather = response.json() day = {1: ’明天’, 2: ’后天’, 3: ’大后天’} weather_lst = [] for num in range(get_date_time): City = weather['cityInfo']['city'] Weatherganmao = weather['data']['ganmao'] Weatherquality = weather['data']['quality'] Weathershidu = weather['data']['shidu'] Weatherwendu = weather['data']['wendu'] Weatherpm25 = str(weather['data']['pm25']) Weatherpm10 = str(weather['data']['pm10']) Dateymd = weather['data']['forecast'][num]['ymd'] Dateweek = weather['data']['forecast'][num]['week'] Sunrise = weather['data']['forecast'][num]['sunrise'] Sunset = weather['data']['forecast'][num]['sunset'] Windfx = weather['data']['forecast'][num]['fx'] Windf1 = weather['data']['forecast'][num]['fl'] Weathertype = weather['data']['forecast'][num]['type'] Weathernotice = weather['data']['forecast'][num]['notice'] Weatherhigh = weather['data']['forecast'][num]['high'] Weatherlow = weather['data']['forecast'][num]['low'] if num == 0: result = ’今日天氣預(yù)報(bào)’ + ’n’ + ’日期： ’ + Dateymd + ’ ’ + Dateweek + ’ ’ + City + ’n’ + ’天氣： ’ + Weathertype + ’ ’ + Windfx + ’ ’ + Windf1 + ’ ’ + Weathernotice + ’n’ + ’當(dāng)前溫度： ’ + Weatherwendu + ’℃’ + ’n’ + ’空氣濕度： ’ + Weathershidu + ’n’ + ’溫度范圍： ’ + Weatherlow + ’’ + ’~’ + ’’ + Weatherhigh + ’n’ + ’污染指數(shù)： ’ + ’PM2.5: ’ + Weatherpm25 + ’ ’ + ’PM10: ’ + Weatherpm10 + ’n’ + ’空氣質(zhì)量： ’ + Weatherquality + ’n’ + ’日出時(shí)間： ’ + Sunrise + ’n’ + ’日落時(shí)間： ’ + Sunset + ’n’ + ’溫馨提示： ’ + Weatherganmao else: which_day = day.get(num,’超出范圍’) result = ’n’ + which_day + ’ ’ + ’天氣預(yù)報(bào)’ + ’n’ + ’日期： ’ + Dateymd + ’ ’ + Dateweek + ’ ’ + City + ’n’ + ’天氣： ’ + Weathertype + ’ ’ + Windfx + ’ ’ + Windf1 + ’ ’ + Weathernotice + ’n’ + ’溫度范圍： ’ + Weatherlow + ’’ + ’~’ + ’’ + Weatherhigh + ’n’ + ’日出時(shí)間： ’ + Sunrise + ’n’ + ’日落時(shí)間： ’ + Sunset + ’n’ + ’溫馨提示： ’ + Weatherganmao weather_lst.append(result) weather_str = ’’ #因?yàn)槟J(rèn)要輸出三天的天氣情況，所以我們需要?jiǎng)?chuàng)建一個(gè)空字符串，然后每迭代一次，就將天氣情況拼接到空字符串中。 for msg in weather_lst: weather_str += msg + ’n’ return weather_str

下面是發(fā)送微信消息

from wxpy import *def send_wx(city_name, who): bot = Bot(cache_path=True) #bot = Bot(console_qr=2, cache_path=’botoo.pkl’) my_friend = bot.friends().search(who)[0] msg = get_weather(city_name) try: my_friend.send(msg) except: my_friend = bot.friends().search(’fei’)[0] my_friend.send(u'發(fā)送失敗')

然后我們還需要寫一個(gè)定時(shí)器，每隔一段時(shí)間便要發(fā)送一次

from threading import Timerdef auto_send(): city_name = ’設(shè)置要發(fā)送的城市’ friend_list = [’要發(fā)送的人’] for who in friend_list: send_wx(city_name,who) global timer timer = Timer(1,auto_send) timer.start()

最后執(zhí)行程序

if __name__ == ’__main__’: timer = Timer(1,auto_send) timer.start()

以上就是python獲取天氣接口給指定微信好友發(fā)天氣預(yù)報(bào)的詳細(xì)內(nèi)容，更多關(guān)于python獲取天氣接口的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！