|
|
|
|
|
|
|
|
|
|
|
|
|
|
CONSUMER_NAME = "task_consumer_" + CONSUMER_NO |
|
|
CONSUMER_NAME = "task_consumer_" + CONSUMER_NO |
|
|
PAYLOAD: Payload | None = None |
|
|
PAYLOAD: Payload | None = None |
|
|
BOOT_AT = datetime.now().isoformat() |
|
|
|
|
|
|
|
|
BOOT_AT = datetime.now().astimezone().isoformat(timespec="milliseconds") |
|
|
PENDING_TASKS = 0 |
|
|
PENDING_TASKS = 0 |
|
|
LAG_TASKS = 0 |
|
|
LAG_TASKS = 0 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if to_page > 0: |
|
|
if to_page > 0: |
|
|
if msg: |
|
|
if msg: |
|
|
msg = f"Page({from_page + 1}~{to_page + 1}): " + msg |
|
|
msg = f"Page({from_page + 1}~{to_page + 1}): " + msg |
|
|
|
|
|
if msg: |
|
|
|
|
|
msg = datetime.now().strftime("%H:%M:%S.%f") + " " + msg |
|
|
d = {"progress_msg": msg} |
|
|
d = {"progress_msg": msg} |
|
|
if prog is not None: |
|
|
if prog is not None: |
|
|
d["progress"] = prog |
|
|
d["progress"] = prog |
|
|
|
|
|
|
|
|
with mt_lock: |
|
|
with mt_lock: |
|
|
heartbeat = json.dumps({ |
|
|
heartbeat = json.dumps({ |
|
|
"name": CONSUMER_NAME, |
|
|
"name": CONSUMER_NAME, |
|
|
"now": now.isoformat(), |
|
|
|
|
|
|
|
|
"now": now.astimezone().isoformat(timespec="milliseconds"), |
|
|
"boot_at": BOOT_AT, |
|
|
"boot_at": BOOT_AT, |
|
|
"pending": PENDING_TASKS, |
|
|
"pending": PENDING_TASKS, |
|
|
"lag": LAG_TASKS, |
|
|
"lag": LAG_TASKS, |