add

injection/data_sync/tasks.py

@@ -18,6 +18,9 @@ from linucb.utils.register_user_tag import RegisterUserTag
 from injection.data_sync.get_session import get_comments, click, login, reply
 from injection.data_sync.get_session import host, user, passwd, db
 
+exec_count_click = 0
+exec_count = 0
+
 
 @shared_task
 def write_to_es(es_type, pk_list, use_batch_query_set=False):
@@ -106,7 +109,7 @@ def sync_user_similar_score():
 
 def auto_click(pk_list):
     logging.info("get--------auto_click--------------:%s" % pk_list)
-    exec_count = 0
+    exec_count_click = 0
     try:
         now = datetime.datetime.now()
         yes_time_str = now.strftime('%Y-%m-%d')
@@ -120,7 +123,6 @@ def auto_click(pk_list):
         topic_id_list = list(data)
         logging.info("Database version : %s " % topic_id_list)
         pc.close()
-        exec_count = 0
         if topic_id_list:
             try:
                 def fun_timer():
@@ -129,17 +131,17 @@ def auto_click(pk_list):
                         click(cookies, topic_id_list[0])
 
                     global timer
-                    global exec_count
+                    global exec_count_click
 
-                    exec_count += 1
-                    if exec_count == 1:
+                    exec_count_click += 1
+                    if exec_count_click == 1:
                         logging.info("----------2-----------")
                         # sleep_time = random.randint(300, 540)
                         sleep_time = 30
                         timer = threading.Timer(sleep_time, fun_timer)
                         timer.start()
 
-                    if exec_count == 2:
+                    if exec_count_click == 2:
                         # sleep_time = random.randint(1000, 1900)
                         logging.info("----------3-----------")
                         sleep_time = 50
@@ -176,7 +178,6 @@ def auto_reply(pk_list):
         topic_id_list = list(data)
         logging.info("Database version : %s " % topic_id_list)
         pc.close()
-        exec_count = 0
         if topic_id_list:
             try: