更新账号均值代码上线

migrateRootSourceId.py

@@ -46,7 +46,7 @@ class UpdateRootSourceId(object):
         :param request_time_stamp:
         :return:
         """
-        start_dt = request_time_stamp - 6 * 24 * 3600
+        start_dt = request_time_stamp - 1 * 24 * 3600
         sql = f"""
             select trace_id, gh_id, account_name, article_title, result1, result2, result3, request_time_stamp
             from long_articles_video 
@@ -124,8 +124,8 @@ def source_id_job():
 
 
 if __name__ == '__main__':
-    source_id_job()
-    # schedule.every().day.at("01:00").do(Functions().job_with_thread, source_id_job)
-    # while True:
-    #     schedule.run_pending()
-    #     time.sleep(1)
+    # source_id_job()
+    schedule.every().day.at("01:00").do(Functions().job_with_thread, source_id_job)
+    while True:
+        schedule.run_pending()
+        time.sleep(1)