diff --git a/migrate_to_data_cache_2.py b/migrate_to_data_cache_2.py new file mode 100644 index 0000000..51e29f1 --- /dev/null +++ b/migrate_to_data_cache_2.py @@ -0,0 +1,6 @@ + +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,to_queue=MORNING_DATA_CACHE_2) diff --git a/request_sender_test.py b/request_sender_test.py index 288a869..bf0fe8b 100644 --- a/request_sender_test.py +++ b/request_sender_test.py @@ -57,7 +57,7 @@ def send_appointment_request(message_queue_name, _contact_list, stop_at_hour=11, logger.info(_contact) _cookiesPublisher = CookiesPublisher(queue_name=message_queue_name) _cookiesPublisher.set_up_connection() - _backUp_cookiesPublisher = CookiesPublisher(queue_name=MORNING_DATA_CACHE_BAK) + _backUp_cookiesPublisher = CookiesPublisher(queue_name=MORNING_DATA_CACHE_2) _backUp_cookiesPublisher.set_up_connection() receiver = AppointmentRequestSender(sub_contact_list=_contact_list, queue_name=message_queue_name, @@ -106,4 +106,4 @@ if __name__ == '__main__': # file_list = ['~/Desktop/15_05_to_test.xlsx', '~/Desktop/16_05_to_test.xlsx'] file_list = ['~/Desktop/contact_list_all.xlsx'] send_request_for_file_list(file_list=file_list, thread_number=2, - data_queue_name=MORNING_DATA_CACHE, stop_at_hour=16, stop_at_mins=30) + data_queue_name=MORNING_DATA_CACHE, stop_at_hour=17, stop_at_mins=30)