总结一下最近使用mysql数据库的代码：进行访问数据库/表——取出表中指定列取值为特定值的所有样本——写入文件
#-*- coding；utf-8 -*- # import sys # reload(sys) #sys.setdefaultencoding( "utf-8" ) importmysql.connector import pandas as pd conn=mysql.connector.connect(host='##.##.###',user='***',password='&&&',database='dw_output',use_unicode=True) cursor=conn.cursor() cursor.execute('usedw_output') cursor.execute("select input_user_name asuser_name,input_mobile_number as mobile_number, input_identity_number asidentity_number from personal_credit_service where customer_id='数据' and src_create_timestamp like '2017-02-27%'order by rand() limit500") values=cursor.fetchall() df=pd.DataFrame(values) df.columns=['user_name','mobile_number','identity_number'] df=df.to_csv('data.csv',index=False) import os import requests from datetime importdatetime import time df=pd.read_csv('data.csv') file_name ='online_score_'+datetime.now().strftime("%Y-%m-%d-%H-%M")+'.txt' with open(os.path.join(os.getcwd(),'TestResult','data',file_name), 'a') as f: #'a' 为append方式 for i in range(len(df)): print i user_name = df.iloc[i,0] mobile_number = df.iloc[i,1] identity_number = df.iloc[i,2] url='https://api.creditx.com/perRisk_creditloan_xScore' request_mode='GET' params ={'user_name':user_name,'mobile_number':mobile_number,'identity_number':identity_number} need_key = 'https' in url response= requests.get(url,params =params,verify = 'ca.crt',cert = ('client.crt','client.key')) content = response.content f.write(content) print 'Tests are successfully done!' print '\n'
