写个脚本一共完成了三件事:
第一,python调用http接口,
第二,把调用到的数据写入mysql数据库,
第三,python调用wsdl接口,获取录音文件,
import 时间
import json
import pprint
import MySQLdb
import urllib
import 操作系统
import urllib2 #调报表接口用
import suds #调录音用
pageNum =,射程(1000)
for a pageNum拷贝:
,,,url =,”http://x.x.x.x: xx/agentProxy/getCallDetail ? RN=118117, callType=1, entId=xxxxx& pwd=61712,开始时间=20170517000000,endTime=20170517235959, pageNum=", +, str (a)
,,,req =, urllib2.Request (url)
,,,res_data =, urllib2.urlopen(要求)
,,,res =, res_data.read ()
,,,data =, json.loads (res)
,,,data1 [0]=,数据
,,,data2 =, data1 (“callDetailArray”)
,,,data4 ,=, data1 (“retCode”)
,,,data5 =, data1 (“retMsg”)
,,,data6 =, data1 (“nextPageNum”)
,,,data7 =, data1 (“RN”)
,,,data8 =, data1 (“entId”)
,,,if len (data1 [' callDetailArray ']),==, 0:
,,,,,,,休息
,,,# print “返回代码:“,data4,“是否成功:“,data5”下一页:“,data6,“RN:“data7,“企业编号:“,data8,“本页总条数:”,len (data1 [' callDetailArray '])
,,,data9 =, len (data1 [' callDetailArray '])
,,,l =,范围(len (data1 [' callDetailArray ']))
,,,for 小姐:李:拷贝
,,,,,,,data3 =, (data2[我])
,,,,,,,data10 =, int (data3 [' sessionId '])
,,,,,,,data11 =,十六进制(data10)
,,,,,,,data12 =, data11 [2]
,,,,,,,data13 =, data12 (: 1)
,,,,,,,data14 =, str (data3 [' resourceId '])
,,,,,,,data15 =, time.strftime (“% Y - % - % d % X”,, time.localtime ())
,,,,,,,url =,”http://x.x.x.x: xx/dcmsWebservice/网络服务/QueryRecord ? wsdl”
,,,,,,,客户=suds.client.Client (url)
,,,,,,,res =, client.service [' QueryRecord '] .queryRecordAddr (“xxxxx”, data14、data14 data13)
,,,,,,,记录=,str (res)
,,,,,,,print 记录
,,,,,,,db =, MySQLdb.connect (“x.x.x.x”,“师姐”,“师姐”,“report_detail charset =, use utf8)
,,,,,,,cursor =, db.cursor ()
,,,,,,,sql =,”““insert into outbound (record_url、sessionId_16 sessionId、resourceId resourceName, resourceDN, skillId, remoteUrl, localUrl,开始时间,endTime,
,,,,,,,,alertDuration talkDuration, acwDuration, ivrDuration, joinDuration, endType insertTime)
,,,,,,,的值(“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”、“% s”)”“\”
,,,,,,,,,,,%(记录、data13 data3 [' sessionId '], data3 [' resourceId '], data3 [' resourceName '], data3 (“resourceDN”),
,,,,,,,,,,,data3 [' skillId '], data3 [' remoteUrl '], data3 [' localUrl '], data3(“开始时间”),data3 [' endTime '], data3 [' alertDuration '], data3 [' talkDuration '], data3 [' acwDuration '], data3 [' ivrDuration '], data3 [' joinDuration '], data3 (“endType”),数据)
,,,,,,,cursor.execute (sql)
,,,,,,,db.commit ()
,,,,,,,cursor.close ()
,,,,,,,db.close ()
,,,,,,,路径=r说:\ \ xxxxxxx记录”
,,,,,,,if record ==, str (5):
,,,,,,,,,,,print “返回5,无录音文件”
,,,,,,,其他的:
,,,,,,,,,,,wav =, record.split (“/?
,,,,,,,,,,,wav1 =, wav [8]
,,,,,,,,,,,dest_dir=os.path.join(路径,wav1)
,,,,,,,,,,,urllib.urlretrieve(记录,dest_dir)
print “本次共同步:“,(a - 1) * 100 - int (data9),“条数据”
