redis定时任务

base/RedisPPData.py

@@ -170,6 +170,8 @@ def BaseInfoEnterprise_task():
         print('定时采集异常', e)
         pass
 
+#企业核心人员
+
 #东方财富网财务数据
 def FinanceFromEast():
     cnx_,cursor_ = cnn11()
@@ -183,6 +185,7 @@ def FinanceFromEast():
         r.rpush('FinanceFromEast:finance_socialCode', item)
     close11(cnx_,cursor_)
 
+#东方财富网财务数据定时任务
 def FinanceFromEase_task():
     # 实例化一个调度器
     scheduler = BlockingScheduler()
@@ -251,7 +254,7 @@ def AnnualEnterpriseXueQ_task():
 def BaseInfoEnterpriseAbroad():
     cnx,cursor = connectSql()
     # 获取国外企业
-    gn_query = "select id from EnterpriseInfo where Place = '2' limit 10 "
+    gn_query = "select SocialCode from EnterpriseInfo where Place = '2' "
     cursor.execute(gn_query)
     gn_result = cursor.fetchall()
     gn_social_list = [item[0] for item in gn_result]
@@ -334,13 +337,13 @@ if __name__ == "__main__":
     # NoticeEnterprise()
     # AnnualEnterpriseIPO()
     # AnnualEnterprise()
-    # BaseInfoEnterpriseAbroad()
-    NewsEnterprise_task()
+    BaseInfoEnterpriseAbroad()
+    # NewsEnterprise_task()
     # NewsEnterprise()
     # BaseInfoEnterprise()
     # FBS()
-    NoticeEnterprise_task()
-    AnnualEnterprise_task()
+    # NoticeEnterprise_task()
+    # AnnualEnterprise_task()
     # NoticeEnterprise()
     # FinanceFromEast()
     log.info(f'====={basecore.getNowTime(1)}=====添加数据成功======耗时：{basecore.getTimeCost(start,time.time())}===')