|
@@ -5,13 +5,12 @@ 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.common import Common
|
|
|
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)
|