优化数据查询

data/samples/mysqlquery.py → data/datasource/dbquery.py

 import pandas as pd
 
-def query(sql,engine_sql):
+def mysql_query(sql,engine_sql):
     '''
     查询大量数据
     :param sql:

data/datasource/mysql_config.ini

@@ -23,5 +23,5 @@ passwd=1q2w3e4r
 db=risk_analysis
 host=172.20.6.9
 port=9030
-user=fengkong_read_only
-passwd=mT2HFUgI
+user=linfang_wang
+passwd=BHWZ3zcZ
\ No newline at end of file

data/samples/xyqbdata.py

 import pandas as pd
 from data.datasource.mysqldb import *
-from data.samples import mysqlquery
+from data.datasource import dbquery
 '''
 目的：提供业务数据，包括 order_no,loan_id,用户类型，支持策略用risk_info,渠道，申请时间，拒绝原因，首逾天数，最大逾期天数，放款期数
 '''
@@ -118,7 +118,7 @@ def query_bydate(start_date,end_date,is_loan=True):
         group by 1,2,3,4,5,6,7,8
         ''' % (start_date,end_date)
 
-    df = mysqlquery.query(sql,engine_analysis_new)
+    df = dbquery.mysql_query(sql,engine_analysis_new)
     df.sort_values(['loan_id'],ascending=True,inplace=True)
     df.drop_duplicates(['loan_id'],keep='last',inplace=True)
     tmp=query_risk_info(df.order_no.tolist())