祝福咱们中老年之视频 修改运行脚本

zhufuzanmenzhonglaonianzhishipin/zhufuzanmenzhonglaonianzhishipin_main/run_zfzmzlnzsp_recommend.py

@@ -1,19 +1,17 @@
-# -*- coding: utf-8 -*-
-
 import argparse
 import random
+
 from mq_http_sdk.mq_client import *
 from mq_http_sdk.mq_consumer import *
 from mq_http_sdk.mq_exception import MQExceptionBase
 
-
+from common.common import Common
 
 sys.path.append(os.getcwd())
-from common.aliyun_log import AliyunLogger
-from common.common import Common
-from common.public import get_consumer, ack_message, task_fun_mq
+from common.public import task_fun_mq, get_consumer, ack_message
 from common.scheduling_db import MysqlHelper
-from zhufuzanmenzhonglaonianzhishipin.zhufuzanmenzhonglaonianzhishipin_recommend.zhufuzanmenzhonglaonianzhishipin_recommend import Zfzmmzlnzspcheduling
+from zhufuzanmenzhonglaonianzhishipin.zhufuzanmenzhonglaonianzhishipin_recommend.zhufuzanmenzhonglaonianzhishipin_recommend import \
+    Zfzmmzlnzspcheduling
 
 def main(log_type, crawler, topic_name, group_id, env):
     consumer = get_consumer(topic_name, group_id)
@@ -22,150 +20,119 @@ def main(log_type, crawler, topic_name, group_id, env):
     wait_seconds = 30
     # 一次最多消费3条（最多可设置为16条）。
     batch = 1
-    Common.logger(log_type, crawler).info(f'{10 * "="}Consume And Ack Message From Topic{10 * "="}\n'
-                                          f'WaitSeconds:{wait_seconds}\n'
-                                          f'TopicName:{topic_name}\n'
-                                          f'MQConsumer:{group_id}')
-    Common.logging(log_type, crawler, env, f'{10 * "="}Consume And Ack Message From Topic{10 * "="}\n'
-                                           f'WaitSeconds:{wait_seconds}\n'
-                                           f'TopicName:{topic_name}\n'
-                                           f'MQConsumer:{group_id}')
-    AliyunLogger.logging(
-        code="1000",
-        platform=crawler,
-        mode=log_type,
-        env=env,
-        message=f'{10 * "="}Consume And Ack Message From Topic{10 * "="}\n'
-                f'WaitSeconds:{wait_seconds}\n'
-                f'TopicName:{topic_name}\n'
-                f'MQConsumer:{group_id}')
+    Common.logger(log_type, crawler).info(
+        f'{10 * "="}Consume And Ack Message From Topic{10 * "="}\n'
+        f"WaitSeconds:{wait_seconds}\n"
+        f"TopicName:{topic_name}\n"
+        f"MQConsumer:{group_id}"
+    )
+    Common.logging(
+        log_type,
+        crawler,
+        env,
+        f'{10 * "="}Consume And Ack Message From Topic{10 * "="}\n'
+        f"WaitSeconds:{wait_seconds}\n"
+        f"TopicName:{topic_name}\n"
+        f"MQConsumer:{group_id}",
+    )
     while True:
         try:
             # 长轮询消费消息。
             recv_msgs = consumer.consume_message(batch, wait_seconds)
             for msg in recv_msgs:
-                Common.logger(log_type, crawler).info(f"Receive\n"
-                                                      f"MessageId:{msg.message_id}\n"
-                                                      f"MessageBodyMD5:{msg.message_body_md5}\n"
-                                                      f"MessageTag:{msg.message_tag}\n"
-                                                      f"ConsumedTimes:{msg.consumed_times}\n"
-                                                      f"PublishTime:{msg.publish_time}\n"
-                                                      f"Body:{msg.message_body}\n"
-                                                      f"NextConsumeTime:{msg.next_consume_time}\n"
-                                                      f"ReceiptHandle:{msg.receipt_handle}\n"
-                                                      f"Properties:{msg.properties}")
-                Common.logging(log_type, crawler, env, f"Receive\n"
-                                                       f"MessageId:{msg.message_id}\n"
-                                                       f"MessageBodyMD5:{msg.message_body_md5}\n"
-                                                       f"MessageTag:{msg.message_tag}\n"
-                                                       f"ConsumedTimes:{msg.consumed_times}\n"
-                                                       f"PublishTime:{msg.publish_time}\n"
-                                                       f"Body:{msg.message_body}\n"
-                                                       f"NextConsumeTime:{msg.next_consume_time}\n"
-                                                       f"ReceiptHandle:{msg.receipt_handle}\n"
-                                                       f"Properties:{msg.properties}")
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f"Receive\n"
-                            f"MessageId:{msg.message_id}\n"
-                            f"MessageBodyMD5:{msg.message_body_md5}\n"
-                            f"MessageTag:{msg.message_tag}\n"
-                            f"ConsumedTimes:{msg.consumed_times}\n"
-                            f"PublishTime:{msg.publish_time}\n"
-                            f"Body:{msg.message_body}\n"
-                            f"NextConsumeTime:{msg.next_consume_time}\n"
-                            f"ReceiptHandle:{msg.receipt_handle}\n"
-                            f"Properties:{msg.properties}"
+                xng_author_start_time = int(time.time())
+                Common.logger(log_type, crawler).info(
+                    f"Receive\n"
+                    f"MessageId:{msg.message_id}\n"
+                    f"MessageBodyMD5:{msg.message_body_md5}\n"
+                    f"MessageTag:{msg.message_tag}\n"
+                    f"ConsumedTimes:{msg.consumed_times}\n"
+                    f"PublishTime:{msg.publish_time}\n"
+                    f"Body:{msg.message_body}\n"
+                    f"NextConsumeTime:{msg.next_consume_time}\n"
+                    f"ReceiptHandle:{msg.receipt_handle}\n"
+                    f"Properties:{msg.properties}"
+                )
+                Common.logging(
+                    log_type,
+                    crawler,
+                    env,
+                    f"Receive\n"
+                    f"MessageId:{msg.message_id}\n"
+                    f"MessageBodyMD5:{msg.message_body_md5}\n"
+                    f"MessageTag:{msg.message_tag}\n"
+                    f"ConsumedTimes:{msg.consumed_times}\n"
+                    f"PublishTime:{msg.publish_time}\n"
+                    f"Body:{msg.message_body}\n"
+                    f"NextConsumeTime:{msg.next_consume_time}\n"
+                    f"ReceiptHandle:{msg.receipt_handle}\n"
+                    f"Properties:{msg.properties}",
                 )
                 # ack_mq_message
-                ack_message(log_type=log_type, crawler=crawler, recv_msgs=recv_msgs, consumer=consumer)
+                ack_message(
+                    log_type=log_type,
+                    crawler=crawler,
+                    recv_msgs=recv_msgs,
+                    consumer=consumer,
+                )
 
                 # 处理爬虫业务
-                task_dict = task_fun_mq(msg.message_body)['task_dict']
-                rule_dict = task_fun_mq(msg.message_body)['rule_dict']
-                task_id = task_dict['id']
-                select_user_sql = f"""select * from crawler_user_v3 where task_id={task_id}"""
-                user_list = MysqlHelper.get_values(log_type, crawler, select_user_sql, env, action="")
-                our_uid_list = []
-                for user in user_list:
-                    our_uid_list.append(user["uid"])
-                our_uid = random.choice(our_uid_list)
-                Common.logger(log_type, crawler).info(f"调度任务:{task_dict}")
-                Common.logging(log_type, crawler, env, f"调度任务:{task_dict}")
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f"调度任务:{task_dict}"
+                task_dict = task_fun_mq(msg.message_body)["task_dict"]
+                rule_dict = task_fun_mq(msg.message_body)["rule_dict"]
+                task_id = task_dict["id"]
+                select_user_sql = (
+                    f"""select * from crawler_user_v3 where task_id={task_id}"""
                 )
-                Common.logger(log_type, crawler).info(f"抓取规则:{rule_dict}")
-                Common.logging(log_type, crawler, env, f"抓取规则:{rule_dict}")
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f"抓取规则:{rule_dict}"
-                )
-                Common.logger(log_type, crawler).info(f"用户列表:{user_list}\n")
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f"用户列表:{user_list}\n"
+                user_list = MysqlHelper.get_values(
+                    log_type, crawler, select_user_sql, env, action=""
                 )
+                Common.logger(log_type, crawler).info(f"调度任务:\n{task_dict}")
+                Common.logging(log_type, crawler, env, f"调度任务:{task_dict}")
+                Common.logger(log_type, crawler).info(f"抓取规则:\n{rule_dict}")
+                Common.logging(log_type, crawler, env, f"抓取规则:{rule_dict}")
+                Common.logger(log_type, crawler).info(f"用户列表:\n{user_list}")
+                Common.logging(log_type, crawler, env, f"用户列表:\n{user_list}")
                 Common.logger(log_type, crawler).info(f'开始抓取:{task_dict["taskName"]}\n')
-                Common.logging(log_type, crawler, env, f'开始抓取:{task_dict["taskName"]}\n')
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f'开始抓取:{task_dict["taskName"]}\n'
+                Common.logging(
+                    log_type, crawler, env, f'开始抓取:{task_dict["taskName"]}\n'
                 )
-                Zfzmmzlnzspcheduling(log_type=log_type,
-                                           crawler=crawler,
-                                           rule_dict=rule_dict,
-                                           our_uid=our_uid,
-                                           env=env)
-                Common.del_charles_files(log_type, crawler)
-                Common.logger(log_type, crawler).info('抓取一轮结束\n')
-                Common.logging(log_type, crawler, env, '抓取一轮结束\n')
-                AliyunLogger.logging(
-                    code="1000",
-                    platform=crawler,
-                    mode=log_type,
+                our_uid_list = []
+                for user in user_list:
+                    our_uid_list.append(user["uid"])
+                our_uid = random.choice(our_uid_list)
+                HH = Zfzmmzlnzspcheduling(
+                    log_type=log_type,
+                    crawler=crawler,
+                    rule_dict=rule_dict,
                     env=env,
-                    message='抓取一轮结束\n'
+                    our_uid=our_uid
                 )
+                for i in range(10):
+                    if HH.download_count >= int(rule_dict.get("videos_cnt", {}).get("min", 10)):
+                        HH.download_count = 0
+                        break
+                    else:
+                        HH.get_videoList(i + 1, 10)
+                        time.sleep(60)
+                Common.logger(log_type, crawler).info("抓取一轮结束\n")
+                Common.logging(log_type, crawler, env, "抓取一轮结束\n")
 
         except MQExceptionBase as err:
             # Topic中没有消息可消费。
             if err.type == "MessageNotExist":
-                Common.logger(log_type, crawler).info(f"No new message! RequestId:{err.req_id}\n")
-                Common.logging(log_type, crawler, env, f"No new message! RequestId:{err.req_id}\n")
-                AliyunLogger.logging(
-                    code="2000",
-                    platform=crawler,
-                    mode=log_type,
-                    env=env,
-                    message=f"No new message! RequestId:{err.req_id}\n"
+                Common.logger(log_type, crawler).info(
+                    f"No new message! RequestId:{err.req_id}\n"
+                )
+                Common.logging(
+                    log_type, crawler, env, f"No new message! RequestId:{err.req_id}\n"
                 )
                 continue
 
-            Common.logger(log_type, crawler).info(f"Consume Message Fail! Exception:{err}\n")
-            Common.logging(log_type, crawler, env, f"Consume Message Fail! Exception:{err}\n")
-            AliyunLogger.logging(
-                code="2000",
-                platform=crawler,
-                mode=log_type,
-                env=env,
-                message=f"Consume Message Fail! Exception:{err}\n"
+            Common.logger(log_type, crawler).info(
+                f"Consume Message Fail! Exception:{err}\n"
+            )
+            Common.logging(
+                log_type, crawler, env, f"Consume Message Fail! Exception:{err}\n"
             )
             time.sleep(2)
             continue
@@ -173,14 +140,16 @@ def main(log_type, crawler, topic_name, group_id, env):
 
 if __name__ == "__main__":
     parser = argparse.ArgumentParser()  ## 新建参数解释器对象
-    parser.add_argument('--log_type', type=str)  ## 添加参数,注明参数类型
-    parser.add_argument('--crawler')  ## 添加参数
-    parser.add_argument('--topic_name')  ## 添加参数
-    parser.add_argument('--group_id')  ## 添加参数
-    parser.add_argument('--env')  ## 添加参数
+    parser.add_argument("--log_type", type=str)  ## 添加参数,注明参数类型
+    parser.add_argument("--crawler")  ## 添加参数
+    parser.add_argument("--topic_name")  ## 添加参数
+    parser.add_argument("--group_id")  ## 添加参数
+    parser.add_argument("--env")  ## 添加参数
     args = parser.parse_args()  ### 参数赋值，也可以通过终端赋值
-    main(log_type=args.log_type,
-         crawler=args.crawler,
-         topic_name=args.topic_name,
-         group_id=args.group_id,
-         env=args.env)
+    main(
+        log_type=args.log_type,
+        crawler=args.crawler,
+        topic_name=args.topic_name,
+        group_id=args.group_id,
+        env=args.env,
+    )