|
@@ -3,6 +3,7 @@
|
|
|
|
|
|
import argparse
|
|
import argparse
|
|
import time
|
|
import time
|
|
|
|
+import random
|
|
|
|
|
|
from mq_http_sdk.mq_client import *
|
|
from mq_http_sdk.mq_client import *
|
|
from mq_http_sdk.mq_consumer import *
|
|
from mq_http_sdk.mq_consumer import *
|
|
@@ -152,11 +153,13 @@ def main(log_type, crawler, topic_name, group_id, env):
|
|
env=env,
|
|
env=env,
|
|
message=f'开始抓取:{task_dict["taskName"]}\n',
|
|
message=f'开始抓取:{task_dict["taskName"]}\n',
|
|
)
|
|
)
|
|
|
|
+ our_uid = random.choice(user_list)
|
|
ZL = ZLNYLScheduling(
|
|
ZL = ZLNYLScheduling(
|
|
log_type=log_type,
|
|
log_type=log_type,
|
|
crawler=crawler,
|
|
crawler=crawler,
|
|
category=3613,
|
|
category=3613,
|
|
rule_dict=rule_dict,
|
|
rule_dict=rule_dict,
|
|
|
|
+ our_uid=our_uid,
|
|
env=env,
|
|
env=env,
|
|
)
|
|
)
|
|
for i in range(100):
|
|
for i in range(100):
|