python调用http接口,并入mysql数据库

import time
import json
import pprint
import MySQLdb
import urllib2
import suds
pageNum = range(1,1000)
for a in pageNum:
    url = "http://x.x.x.x:xx/agentProxy/getCallDetail?RN=118117&callType=1&entId=xxxx&pwd=xxxx&startTime=20170516000000&endTime=20170516235959&pageNum=" + str(a)
    req = urllib2.Request(url)
    res_data = urllib2.urlopen(req)
    res = res_data.read()
    data = json.loads(res)
    data1 = data[0]
    data2 = data1["callDetailArray"]
    data4  = data1["retCode"]
    data5 = data1["retMsg"]
    data6 = data1["nextPageNum"]
    data7 = data1["RN"]
    data8 = data1["entId"]
    if len(data1[‘callDetailArray‘]) == 0:
        break
    #print "返回代码:",data4,"是否成功:",data5,"下一页:",data6,"RN:",data7,"企业编号:",data8,"本页总条数:",len(data1[‘callDetailArray‘])
    data9 = len(data1[‘callDetailArray‘])
    l = range(len(data1[‘callDetailArray‘]))
    for i in l:
        data3 = (data2[i])
        data10 = int(data3[‘sessionId‘])
        data11 = hex(data10)
        data12 = data11[2:]
        data13 = data12[:-1]
        data14 = str(data3[‘resourceId‘])
        data15 = time.strftime("%Y-%m-%d %X", time.localtime())
        url = "http://x.x.x.x:xx/dcmsWebservice/webservice/QueryRecord?wsdl"
        client=suds.client.Client(url)
        res = client.service[‘QueryRecord‘].queryRecordAddr("xxxxxxxxx",data14,data14,data13)
        record= str(res)
        print record
        db = MySQLdb.connect("x.x.x.x","ucds","ucds","report_detail",charset = "utf8")
        cursor = db.cursor()
        sql = """insert into outbound (record_url,sessionId_16,sessionId,resourceId,resourceName,resourceDN,skillId,remoteUrl,localUrl,startTime,endTime,
        alertDuration,talkDuration,acwDuration,ivrDuration,joinDuration,endType,insertTime)
        values("%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s","%s")"""            %(record,data13,data3[‘sessionId‘],data3[‘resourceId‘],data3[‘resourceName‘],data3[‘resourceDN‘],
            data3[‘skillId‘],data3[‘remoteUrl‘],data3[‘localUrl‘],data3[‘startTime‘],data3[‘endTime‘],data3[‘alertDuration‘],data3[‘talkDuration‘],data3[‘acwDuration‘],data3[‘ivrDuration‘],data3[‘joinDuration‘],data3[‘endType‘],data15)
        cursor.execute(sql)
        db.commit()
        cursor.close()
        db.close()
print "本次共同步:",(a-1)*100-int(data9),"条数据"
时间: 2024-10-17 22:19:27

python调用http接口,并入mysql数据库的相关文章

Python调用webservice接口

python调用webservice接口,这里我们使用suds包 如果没有直接cmd命令安装subs包 pip suds install 安装成功会有提示成功字样. ------------------------------ 首先导入包 先查看一下webservice提供哪些类型及方法,之后我们才知道怎么调用,传哪些参数. from suds.client import Client from suds.transport.https import HttpAuthenticated #web

python调用ice接口

今天用python调用ice接口,遇到如下提示 ImportError: No module named Ice 解决方案是 set PYTHONPATH=C:\Program Files\ZeroC\Ice-3.4.1\python 然后又提示 import IcePy ImportError: DLL load failed: The specified module could not be found. 在网上看到别人是如下配置即可 C:\> set PATH=C:\Python26;C

JDBC课程1-实现Driver接口连接mysql数据库、通用的数据库连接方法(使用文件jdbc.properties)

package day_18; import jdk.internal.util.xml.impl.Input; import org.junit.Test; import java.io.InputStream; import java.net.URL; import java.sql.*; import java.util.Properties; import java.util.logging.Logger; /** * Driver 只是一个接口,数据库厂商必须提供的接口,能从中获取数据

48.Python中ORM模型实现mysql数据库基本的增删改查操作

首先需要配置settings.py文件中的DATABASES与数据库的连接信息, DATABASES = { 'default': { 'ENGINE': 'django.db.backends.mysql', 'NAME': 'orm_intro_dem', 'USER': 'root', 'PASSWORD': 'root', 'HOST': '127.0.0.1', 'PORT': '3306', } } 之后将创建的app添加到settings.py文件中的INSTALLED_APPS中

python django 站点管理 配置mysql数据库

运行命令mysql -uroot -p进入mysql 新建一个数据库mydatabase 在/mysite/mysite目录下 编辑settings.py文件: 默认数据库为sqlite: DATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': 'mydatabase', } } mysql数据库配置: DATABASES = { 'default': { 'ENGINE': 'django.db.ba

JSP 实现 之 调用java方法实现MySQL数据库备份和恢复

package cn.qm.db; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStreamReader; public class Command { /* public static void main(String[] args) throws IOException { Command com = new Com

基于docker的php调用基于docker的mysql数据库的方法

1:建立基于docker的mysql,参考 Mac上将brew安装的MySql改用Docker执行 2:建立基于docker?php image 在当前目录,建立Dockerfile,内容如下 FROM php:7.0-cli MAINTAINER Terry Zhang <[email protected]> RUN docker-php-ext-install pdo_mysql mysqli 3.建立php镜像 docker build -t php-mysql . 4. 编写php脚本

Python MySQLdb模块连接操作mysql数据库实例_python

mysql是一个优秀的开源数据库,它现在的应用非常的广泛,因此很有必要简单的介绍一下用python操作mysql数据库的方法.python操作数据库需要安装一个第三方的模块,在http://mysql-python.sourceforge.net/有下载和文档. 由于python的数据库模块有专门的数据库模块的规范,所以,其实不管使用哪种数据库的方法都大同小异的,这里就给出一段示范的代码: #-*- encoding: gb2312 -*- import os, sys, string impo

python在windows下连接mysql数据库

一,安装MySQL-python python 连接mysql数据库需要 Python interface to Mysql包,包名为 MySQL-python ,PyPI上现在到了1.2.5版本.MySQL-python在windows下是通过.exe文件的installer安装的, 前提是已经安装的python需要写入注册表,参考这篇文章:windows安装python2.7后的注册(registry)问题. 然后开始安装MySQL-python,不过这里有个坑,从PyPI上下载的MySQL