diff --git a/request_sender_test.py b/request_sender_test.py index ce0555d..ad07aae 100644 --- a/request_sender_test.py +++ b/request_sender_test.py @@ -85,7 +85,7 @@ def start_send_requests(thread_number, contact_list, data_queue_name=MORNING_DAT _thread.join() -def send_request_for_file_list(_file_list: list[str], thread_number: int = 20, data_queue_name=MORNING_DATA_CACHE): +def send_request_for_file_list(file_list: list[str], thread_number: int = 20, data_queue_name=MORNING_DATA_CACHE): for _file_path in file_list: logger.info("send request for file: " + _file_path) _contact_list = read_contacts(_file_path) @@ -94,6 +94,9 @@ def send_request_for_file_list(_file_list: list[str], thread_number: int = 20, d if __name__ == '__main__': - file_list = ['~/Desktop/09_05_to_test.xlsx','~/Desktop/contact_list_2024-05-13.xlsx'] - send_request_for_file_list(_file_list=file_list, thread_number=5, - data_queue_name=MORNING_DATA_CACHE_2) + file_list = ['~/Desktop/contact_list_2024-05-19.xlsx', '~/Desktop/contact_list_2024-05-17.xlsx', + '~/Desktop/15_05_to_test.xlsx'] + # file_list = ['~/Desktop/15_05_to_test.xlsx', '~/Desktop/16_05_to_test.xlsx'] + # file_list = ['~/Desktop/contact_all_old.xlsx'] + send_request_for_file_list(file_list=file_list, thread_number=32, + data_queue_name=MORNING_DATA_CACHE) diff --git a/scheduler_test.py b/scheduler_test.py index 6f2bfae..2ffb563 100644 --- a/scheduler_test.py +++ b/scheduler_test.py @@ -1,11 +1,16 @@ from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor from apscheduler.schedulers.blocking import BlockingScheduler -from request_sender_test import start_send_requests +from queue_message.CookiesPublisher import MORNING_DATA_CACHE +from request_sender_test import send_request_for_file_list def start_book_appointment(): - start_send_requests(thread_number=31, file_path='~/Desktop/contact_list_2024-05-16.xlsx') + file_list = ['~/Desktop/contact_list_2024-05-19.xlsx', + '~/Desktop/contact_list_2024-05-17.xlsx', + '~/Desktop/15_05_to_test.xlsx'] + send_request_for_file_list(_file_list=file_list, thread_number=32, + data_queue_name=MORNING_DATA_CACHE) def start_check_results_job(sched):