udpate

crawler_sys/framework/update_data_in_target_releasers_multi_process_by_date_from_redis.py

@@ -139,7 +139,8 @@ kwargs_dict = {
 def get_task_from_redis():
     while True:
         try:
-            now = datetime.datetime.now()
+            print('----------------------')
+            # now = datetime.datetime.now()
             # if now.hour >= exit_hour:
             #     sys.exit()
             res = rds_1.hgetall("process_num")
@@ -174,6 +175,7 @@ def single_thead(processe,name):
         end_time = int(now.timestamp() * 1e3)
         for count, platform in enumerate(get_task_from_redis()):
             now = datetime.datetime.now()
+            print(count,platform)
             try:
                 count_false = 0
                 releaser_dic_str = rds_1.blpop(platform)