修改志伟ctr统计文件

eda/gray_stat/ffm_get_data.py

@@ -22,11 +22,10 @@ def get_yesterday_date():
 def get_data():
     conn2db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
     cursor = conn2db.cursor()
-    sql = "select device_id from eagle.ffm_diary_queue where device_id regexp '[5|6]$'"
+    sql = "select device_id from eagle.ffm_diary_queue_temp where device_id regexp '[5|6]$'"
     cursor.execute(sql)
     result = cursor.fetchall()
     device_id = tuple(pd.DataFrame(list(result))[0].values.tolist())
-    print(device_id[0:1])
     cursor.close()
     return device_id
 

eda/gray_stat/yesterday.py

+# -*- coding: UTF-8 -*-
+import pymysql
+import datetime
+import pandas as pd
+
+DIRECTORY_PATH="/data2/ffm/"
+
+def get_yesterday_date():
+    #自动获取昨天的日期,如"2018-08-08"
+    """
+    :rtype : str
+    """
+    today = datetime.date.today()
+    yesterday = today - datetime.timedelta(days=1)
+    yesterday = yesterday.strftime("%Y-%m-%d")
+    print(yesterday)
+    return yesterday
+    #today = datetime.date.today().strftime("%Y%m%d")
+    #return today
+
+
+def get_data():
+    conn2db = pymysql.connect(host='10.66.157.22', port=4000, user='root', passwd='3SYz54LS9#^9sBvC', db='eagle')
+    cursor = conn2db.cursor()
+    sql = "select device_id from eagle.ffm_diary_queue_temp where device_id regexp '[5|6]$'"
+    cursor.execute(sql)
+    result = cursor.fetchall()
+    pd.DataFrame(list(result)).to_csv("/data2/ffm/yesterday.csv")
+    cursor.close()
+
+
+
+if __name__ == "__main__":
+    get_data()