|
|
@@ -4,12 +4,12 @@ from mq_http_sdk.mq_consumer import *
|
|
|
from mq_http_sdk.mq_exception import MQExceptionBase
|
|
|
|
|
|
|
|
|
-
|
|
|
sys.path.append(os.getcwd())
|
|
|
from common.public import task_fun_mq, get_consumer, ack_message
|
|
|
from common.scheduling_db import MysqlHelper
|
|
|
from common import AliyunLogger
|
|
|
-from jierikaixinzhufusonggeinin.jierikaixinzhufusonggeinin_recommend.jierikaixinzhufusonggeinin_recommend import Jrkxzfsgnspcheduling
|
|
|
+from laoyoumeirizhufu.laoyoumeirizhufu_recommend.laoyoumeirizhufu_recommend import Lymrzhspcheduling
|
|
|
+
|
|
|
def main(log_type, crawler, topic_name, group_id, env):
|
|
|
consumer = get_consumer(topic_name, group_id)
|
|
|
# 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3秒，3秒内如果有消息可以消费则立即返回响应。
|
|
|
@@ -93,9 +93,9 @@ def main(log_type, crawler, topic_name, group_id, env):
|
|
|
platform=crawler,
|
|
|
mode=log_type,
|
|
|
env=env,
|
|
|
- message="开始抓取节日开心祝福送给您——推荐",
|
|
|
+ message="开始抓取老友每日祝福——推荐",
|
|
|
)
|
|
|
- HH = Jrkxzfsgnspcheduling(
|
|
|
+ HH = Lymrzhspcheduling(
|
|
|
platform=crawler,
|
|
|
mode=log_type,
|
|
|
rule_dict=rule_dict,
|
|
|
@@ -108,7 +108,7 @@ def main(log_type, crawler, topic_name, group_id, env):
|
|
|
platform=crawler,
|
|
|
mode=log_type,
|
|
|
env=env,
|
|
|
- message="完成抓取——节日开心祝福送给您",
|
|
|
+ message="完成抓取——老友每日祝福",
|
|
|
)
|
|
|
AliyunLogger.logging(
|
|
|
code="1004", platform=crawler, mode=log_type, env=env,message="结束一轮抓取"
|
