資源簡(jiǎn)介
爬取某塊區(qū)域的實(shí)時(shí)交通態(tài)勢(shì)數(shù)據(jù),并存入mysql數(shù)據(jù)庫(kù);替換代碼中的坐標(biāo),換成自己想要爬取的地區(qū)坐標(biāo)
代碼片段和文件信息
import?requests
import?json
import?time
import?psycopg2
import?pymysql
import?threading
def?getGaodeTrafficStatus(keyfurlcurrentTime):
????insert_list?=?[]
????TrafficStatusUrl?=?furl;
????res?=?requests.get(url=TrafficStatusUrl).content;
????res=res.decode(“utf-8“)
????total_json?=?json.loads(res);
????print(total_json)
????jsondata?=?total_json[‘trafficinfo‘][‘roads‘];
????currentDate?=?time.strftime(“%Y-%m-%d“?time.localtime());
????if?any(jsondata):
????????for?i?in?jsondata:
????????????name?=?i[‘name‘]
????????????status?=?i[‘status‘]
????????????direction?=?i[‘direction‘]
????????????angle?=?i[‘a(chǎn)ngle‘]
????????????speed?=?i.get(‘speed‘);
????????????
????????????if?speed?==?None:
????????????????speed?=?None;
????????????lcodes?=?i[‘lcodes‘]
????????????polyline?=?i[‘polyline‘]
????????????list?=?[name?status?direction?angle?lcodes?polyline?currentDate?currentTime?speed];
????????????insert_list.append(list);
????????db?=?pymysql.connect(“l(fā)ocalhost““root““root““springboot“)
????????cursor?=?db.cursor()
????????print(len(insert_list))
????????for?i?in?insert_list:
????????????print(len(i))
????????????if?len(i):
????????????????print(“insert?into?t_system_position?(namestatusdirectionanglelcodespolyline?currentDate?currentTime?speed)?values(‘%s‘‘%s‘‘%s‘‘%s‘‘%s‘‘%s‘‘%s‘‘%s‘‘%s‘)“?%?(i[0]i[1]i[2]i[3]i[4]i[5]i[6]i[7]i[8]))
?
評(píng)論
共有 條評(píng)論