From 8bba5eb2f10dd674d1bec9a4b2f120f80152d1e5 Mon Sep 17 00:00:00 2001 From: PAN Lei Date: Tue, 3 Dec 2024 18:46:42 +0100 Subject: [PATCH] added method to remove message --- migrate_to_data_cache_2.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/migrate_to_data_cache_2.py b/migrate_to_data_cache_2.py index 6ee4549..4cca933 100644 --- a/migrate_to_data_cache_2.py +++ b/migrate_to_data_cache_2.py @@ -3,6 +3,6 @@ from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CA from workers.MessagerTransporter import migrate_message_to_queue, empty_message_just_to if __name__ == '__main__': - migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_BAK, to_queue=MORNING_DATA_CACHE) - # empty_message_just_to(2000, queue_name=MORNING_DATA_CACHE_BAK) + # migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_BAK, to_queue=MORNING_DATA_CACHE) + empty_message_just_to(20000, queue_name=MORNING_DATA_CACHE_BAK) # migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_BAK,to_queue=REQUEST_DATA_QUEUE_DE)