From d74904666c7e49a07438ad7a9241a049df3ae434 Mon Sep 17 00:00:00 2001 From: PAN Lei Date: Fri, 26 Apr 2024 12:27:13 +0200 Subject: [PATCH] use 25 segments --- queue_message/CookiesPublisher.py | 1 + request_sender_test.py | 7 ++++--- scheduler_test.py | 2 +- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/queue_message/CookiesPublisher.py b/queue_message/CookiesPublisher.py index 2dea9fd..5561f7d 100644 --- a/queue_message/CookiesPublisher.py +++ b/queue_message/CookiesPublisher.py @@ -7,6 +7,7 @@ REQUEST_DATA_QUEUE_TEST = 'REQUEST_DATA_TEST' TEST_QUEUE = 'TEST_QUEUE' SHARED_OBJECT = 'SHARED_OBJECT' MORNING_DATA_CACHE = 'MORNING_DATA_CACHE' +MORNING_DATA_CACHE_2 = 'MORNING_DATA_CACHE_2' MORNING_DATA_CACHE_BAK = 'MORNING_DATA_CACHE_BAK' REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE' REQUEST_DATA_OBJECT = 'REQUEST_DATA_OBJECT' diff --git a/request_sender_test.py b/request_sender_test.py index 227b894..824d281 100644 --- a/request_sender_test.py +++ b/request_sender_test.py @@ -6,7 +6,8 @@ from threading import Thread from db.mongo_manager import MONGO_STORE_MANAGER from excel_reader import read_contacts from models.contact_pojo import ContactPojo -from queue_message.CookiesPublisher import CookiesPublisher, SHARED_OBJECT, TEST_QUEUE, MORNING_DATA_CACHE +from queue_message.CookiesPublisher import CookiesPublisher, SHARED_OBJECT, TEST_QUEUE, MORNING_DATA_CACHE, \ + MORNING_DATA_CACHE_2 from queue_message.appointmentrequestsender import AppointmentRequestSender from utiles import is_time_between from utils.AppLogging import init_logger @@ -78,11 +79,11 @@ def start_send_requests(thread_number, file_path): logger.info("segment is {}".format(i)) _step = int(len(_contact_list_to_book) / _segment_number) _sublist = _contact_list_to_book[i * _step:_step * (i + 1)] - _thread1 = Thread(target=send_appointment_request, args=(MORNING_DATA_CACHE, _sublist)) + _thread1 = Thread(target=send_appointment_request, args=(MORNING_DATA_CACHE_2, _sublist)) last_thread = _thread1 _thread1.start() last_thread.join() if __name__ == '__main__': - start_send_requests(thread_number=25, file_path='~/Desktop/24_04_to_test.xlsx') + start_send_requests(thread_number=25, file_path='~/Desktop/contact_list_2024-04-17.xlsx') diff --git a/scheduler_test.py b/scheduler_test.py index 47e5c3d..c2c3ede 100644 --- a/scheduler_test.py +++ b/scheduler_test.py @@ -5,7 +5,7 @@ from request_sender_test import start_send_requests def start_book_appointment(): - start_send_requests(thread_number=25, file_path='~/Desktop/contact_list_2024-04-24.xlsx') + start_send_requests(thread_number=25, file_path='~/Desktop/contact_list_2024-04-25_2.xlsx') def start_check_results_job(sched):