|
@@ -8,7 +8,7 @@ from mq_http_sdk.mq_exception import MQExceptionBase
|
|
|
|
|
|
|
|
|
|
sys.path.append(os.getcwd())
|
|
sys.path.append(os.getcwd())
|
|
-from laonianduiwu.laonianduiwu_recommend.lndwjckd_recommend import LndwzfRecommend
|
|
|
|
|
|
+from laonianduiwu.laonianduiwu_recommend.lndwjckd_recommend import LndwjckdRecommend
|
|
|
|
|
|
from common.common import Common
|
|
from common.common import Common
|
|
from common.public import get_consumer, ack_message, task_fun_mq
|
|
from common.public import get_consumer, ack_message, task_fun_mq
|
|
@@ -75,7 +75,7 @@ def main(log_type, crawler, topic_name, group_id, env):
|
|
Common.logger(log_type, crawler).info(f"用户列表:{user_list}\n")
|
|
Common.logger(log_type, crawler).info(f"用户列表:{user_list}\n")
|
|
Common.logger(log_type, crawler).info(f'开始抓取:{task_dict["taskName"]}\n')
|
|
Common.logger(log_type, crawler).info(f'开始抓取:{task_dict["taskName"]}\n')
|
|
Common.logging(log_type, crawler, env, f'开始抓取:{task_dict["taskName"]}\n')
|
|
Common.logging(log_type, crawler, env, f'开始抓取:{task_dict["taskName"]}\n')
|
|
- LndwzfRecommend.get_videoList(log_type=log_type,
|
|
|
|
|
|
+ LndwjckdRecommend.get_videoList(log_type=log_type,
|
|
crawler=crawler,
|
|
crawler=crawler,
|
|
rule_dict=rule_dict,
|
|
rule_dict=rule_dict,
|
|
our_uid=our_uid,
|
|
our_uid=our_uid,
|