use separate process to migrate messages

2024-05-02 22:26:45 +02:00
parent 5db5aadb12
commit 95db3be637
1 changed files with 10 additions and 3 deletions
@@ -1,6 +1,13 @@
-from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CACHE
+from multiprocessing import Process
+
+from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CACHE, MORNING_DATA_CACHE_BAK
 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)
+    p1 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE_2, MORNING_DATA_CACHE_BAK))
+    p1.start()
+    p2 = Process(target=migrate_message_to_queue, args=(MORNING_DATA_CACHE, MORNING_DATA_CACHE_BAK))
+    p2.start()
+    p2.join()
+    # migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)
+    # migrate_message_to_queue(from_queue=MORNING_DATA_CACHE)