Skip to content

C
crawler
Commit e830adf9 authored by litaolemo's avatar litaolemo
Browse files
Options

update

parent 69c39698
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 0 deletions
crawler_sys/framework/update_data_in_target_releasers_multi_process_by_date_from_redis.py
View file @ e830adf9
...@@ -155,9 +155,12 @@ def get_task_from_redis(): ...@@ -155,9 +155,12 @@ def get_task_from_redis():
print("line 152 error",e) print("line 152 error",e)
continue continue
try: try:
print("rds_1.llen(platform)" ,rds_1.llen(platform))
if rds_1.llen(platform) > 0: if rds_1.llen(platform) > 0:
print("process_num",process_num)
if process_num: if process_num:
if res.get(platform): if res.get(platform):
print(res.get(platform))
if int(res.get(platform)) > int(process_num): if int(res.get(platform)) > int(process_num):
print("get platfrom %s" % platform) print("get platfrom %s" % platform)
rds_1.incr(platform_str) rds_1.incr(platform_str)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment