add

majia/auto_instant_click.py

@@ -15,7 +15,6 @@ from get_session import get_comments, get_cookies, click, time_conv, login, repl
 @shared_task
 def auto_click(es_type, id):
     try:
-
         pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
         cursor = pc.cursor()
         cursor.execute(
@@ -68,7 +67,7 @@ def auto_click(es_type, id):
 
 
 @shared_task
-def auto_reply(id):
+def auto_reply(es_type,id):
     try:
         pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
         cursor = pc.cursor()
@@ -115,5 +114,3 @@ def auto_reply(id):
     except:
         logging.error("catch exception,main:%s" % traceback.format_exc())
 
-# 发帖瞬时：[1 - 5]个马甲点赞
-# 1. 用户发帖后，[瞬时]，1-3条评论

physical/celery_task_router.py

@@ -14,6 +14,9 @@ class CeleryTaskRouter(object):
         ],
         "majia-alpha": [
             'injection.data_sync.auto_instant_click.auto_click',
+        ],
+        "majia-alpha": [
+            'injection.data_sync.auto_instant_click.auto_reply',
         ]
     }