|
|
@@ -8,7 +8,8 @@ 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 kaixinxingfudaowanjia.kaixinxingfudaowanjia_recommend.kaixinxingfudaowanjia_recommend import Kxxfdwjspcheduling
|
|
|
+from meihaoxinghe.meihaoxinghe_recommend.meihaoxinghe_recommend import MHXHspcheduling
|
|
|
+
|
|
|
|
|
|
|
|
|
def main(log_type, crawler, topic_name, group_id, env):
|
|
|
@@ -96,7 +97,7 @@ def main(log_type, crawler, topic_name, group_id, env):
|
|
|
env=env,
|
|
|
message="开始抓取美好星河——推荐",
|
|
|
)
|
|
|
- main_process = Kxxfdwjspcheduling(
|
|
|
+ main_process = MHXHspcheduling(
|
|
|
platform=crawler,
|
|
|
mode=log_type,
|
|
|
rule_dict=rule_dict,
|
