第一个python脚本,调url接口,返回json格式数据,然后解析json,提取字段,插入postgresql库

#!/usr/bin/python
# encoding: utf8
import os
import sys
import time
import stat
import urllib
import httplib
import datetime
import json
import psycopg2  

reload(sys)
sys.setdefaultencoding('utf-8')

#连接数据库
conn = psycopg2.connect(database='work_test',user='postgres',password='123456',host='127.0.0.1',port='5432')  
cur = conn.cursor()  

#µ÷½Ó¿Úº¯Êý
def getdata():  
	#设置日期
	today = datetime.date.today().strftime('%Y%m%d') if len(sys.argv)<2 else sys.argv[1]
	yesterday = (datetime.datetime.strptime(today,'%Y%m%d')-datetime.timedelta(days=1)).strftime('%Y%m%d')
	print yesterday

	try:
		#插入数据前,先删除表中数据
		print 'delete old data...'
		cur.execute("delete from location_sdk_pv where f_date=%(f_date)s",{'f_date':yesterday})
		print "finish deleting"

		SDKPVURL='http://real_time.xxoo.com/api/getTotalLocationCountByDate.php?date='+str(yesterday)
		data=urllib.urlopen(SDKPVURL).read()  

		jo = json.loads(data)
		pv=jo['data']
		print(pv)

		cur.execute("insert into location_sdk_pv(f_date,pv) values(%(f_date)s,%(pv)s);",{'f_date':yesterday,'pv':pv})
		print yesterday,pv
	except Exception,ex:
		print Exception,ex
getdata()

 
conn.commit()  
cur.close()  
conn.close() 


Logo

CSDN联合极客时间,共同打造面向开发者的精品内容学习社区,助力成长!

更多推荐