Skip to content

lichenggang / tas_monitor

Go to a project
Commit 4eb51347 by 陈森彬
Options

update

parent a5a2b9e3
Inline Side-by-side
Showing with 1 additions and 0 deletions
crawler_process.py
...@@ -25,6 +25,7 @@ dashboard = MySqlOperator('dashboard') ...@@ -25,6 +25,7 @@ dashboard = MySqlOperator('dashboard')
def get_process_task(task_code): def get_process_task(task_code):
keys = task_redis.keys(task_code + '_*') keys = task_redis.keys(task_code + '_*')
print(keys)
keys_len = sum([task_redis.llen(k) for k in keys]) keys_len = sum([task_redis.llen(k) for k in keys])
abnormal_keys = task_redis.keys('abnormal_' + task_code + '_*') abnormal_keys = task_redis.keys('abnormal_' + task_code + '_*')
abnormal_keys_len = sum([task_redis.llen(k) for k in abnormal_keys]) abnormal_keys_len = sum([task_redis.llen(k) for k in abnormal_keys])
......
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 sign in to comment