# -*- coding:utf-8 -*-
import requests
import json
from pymysql import *
#差评接口
url = "xxx"
header={'content-type':'application/x-www-form-urlencoded'}
#入参
data={'appId':'xxx','pagenum':'1','pagetity':'10','regionCode':'xxx'}
timeout=1000
r = requests.post(url=url, data=data, timeout=timeout)
result= r.json()
rowsData = result.get('datalist').get('rows')
#建立和数据库系统的连接
conn = pymysql.connect(host='xxx', port=xxx, database='xxx', user='xxx', password='xxx', charset='utf8')
for field in rowsData:
#获取相应数据
ITEM_NAME = field.get('ITEM_NAME')
DETAIL_APPRAT = field.get('DETAIL_APPRAT')
USER_NAME = field.get('USER_NAME')
USER_PHONE = field.get('USER_PHONE')
APPRAT_TIME = field.get('APPRAT_TIME')
data = (ITEM_NAME, DETAIL_APPRAT, USER_NAME, USER_PHONE, APPRAT_TIME)
print(data)
#获取操作游标
cursor = conn.cursor()
try:
#执行sql语句
sql = "insert into xxx(blsx,pjnr,pjr,lxfs,tcrq) values(%s,%s,%s,%s,%s)"
cursor.executemany(sql,data)
#事物提交
conn.commit()
except Exception as err:
conn.rollback()
conn.close()
Python解析接口
猜你喜欢
转载自blog.csdn.net/weixin_43233971/article/details/115210559
今日推荐
周排行