panleicim/appointment_request
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

stop consuming if all item finished

Browse Source
This commit is contained in:
PAN Lei
2024-06-13 18:22:56 +02:00
parent a516f1eb53
commit 4f8eec2335
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
workers/result_link_checker.py
+4 -3
View File
@@ -153,6 +153,7 @@ class ResultLinkChecker(threading.Thread):
print("empty list, no need to ack") print("empty list, no need to ack")
time.sleep(60) time.sleep(60)
ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True) ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True)
self.channel.stop_consuming()
def start_check_links(_queue_name, link_list, logger): def start_check_links(_queue_name, link_list, logger):
@@ -175,8 +176,8 @@ def check_all_links(_segment_number=2):
if _item.url_validated is not None and _item.url_validated is True: if _item.url_validated is not None and _item.url_validated is True:
_link_list.append(_item.url) _link_list.append(_item.url)
print(_link_list) print(_link_list)
# _link_list_filted = _link_list[4000:-1] _link_list_filted = _link_list
_link_list_filted = _link_list[-4:-1] # _link_list_filted = _link_list[-4:-1]
thread_list = [] thread_list = []
for i in range(0, _segment_number): for i in range(0, _segment_number):
logger.info("segment is {}".format(i)) logger.info("segment is {}".format(i))
@@ -192,4 +193,4 @@ def check_all_links(_segment_number=2):
if __name__ == '__main__': if __name__ == '__main__':
check_all_links(_segment_number=2) check_all_links(_segment_number=30)