|
@@ -10,8 +10,8 @@ sys.path.append(os.getcwd())
|
|
|
from common.common import Common
|
|
|
from common.public import get_consumer, ack_message, task_fun_mq
|
|
|
from common.scheduling_db import MysqlHelper
|
|
|
-# from kanyikan.kanyikan_recommend.kanyikan_recommend0705 import KanyikanRecommend
|
|
|
-from kanyikan.kanyikan_recommend.kykjk_recommend import KanyikanRecommend
|
|
|
+from kanyikan.kanyikan_recommend.kanyikan_recommend0705 import KanyikanRecommend
|
|
|
+# from kanyikan.kanyikan_recommend.kykjk_recommend import KanyikanRecommend
|
|
|
|
|
|
|
|
|
def main(log_type, crawler, topic_name, group_id, env):
|