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

try to programme message migration

Browse Source
This commit is contained in:
PAN Lei
2024-05-02 17:32:18 +02:00
parent b737058997
commit 5db5aadb12
2 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
migrate_cached_request_data.py
+6
View File
@@ -0,0 +1,6 @@
from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CACHE
from workers.MessagerTransporter import migrate_message_to_queue
if __name__ == '__main__':
migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)
migrate_message_to_queue(from_queue=MORNING_DATA_CACHE)
workers/MessagerTransporter.py
+12 -3
View File
@@ -39,9 +39,18 @@ class MessageTransporter(threading.Thread):
exit(0) exit(0)
if __name__ == '__main__': def migrate_message_to_queue(from_queue, to_queue="MORNING_DATA_CACHE_BAK"):
cookiesPublisher = CookiesPublisher(queue_name="MORNING_DATA_CACHE_BAK") cookiesPublisher = CookiesPublisher(queue_name=to_queue)
cookiesPublisher.set_up_connection() cookiesPublisher.set_up_connection()
message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=MORNING_DATA_CACHE) message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=from_queue)
message_transporter.set_up_connection() message_transporter.set_up_connection()
message_transporter.listen_to_queue() message_transporter.listen_to_queue()
if __name__ == '__main__':
migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)
# cookiesPublisher = CookiesPublisher(queue_name="MORNING_DATA_CACHE_BAK")
# cookiesPublisher.set_up_connection()
# message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=MORNING_DATA_CACHE)
# message_transporter.set_up_connection()
# message_transporter.listen_to_queue()