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

correction for param name

Browse Source
This commit is contained in:
PAN Lei
2024-05-20 11:10:27 +02:00
parent 21122ea540
commit 7225bf056e
2 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
request_sender_test.py
+7 -4
View File
@@ -85,7 +85,7 @@ def start_send_requests(thread_number, contact_list, data_queue_name=MORNING_DAT
_thread.join() _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: for _file_path in file_list:
logger.info("send request for file: " + _file_path) logger.info("send request for file: " + _file_path)
_contact_list = read_contacts(_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__': if __name__ == '__main__':
file_list = ['~/Desktop/09_05_to_test.xlsx','~/Desktop/contact_list_2024-05-13.xlsx'] file_list = ['~/Desktop/contact_list_2024-05-19.xlsx', '~/Desktop/contact_list_2024-05-17.xlsx',
send_request_for_file_list(_file_list=file_list, thread_number=5, '~/Desktop/15_05_to_test.xlsx']
data_queue_name=MORNING_DATA_CACHE_2) # 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)
scheduler_test.py
+7 -2
View File
@@ -1,11 +1,16 @@
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from apscheduler.schedulers.blocking import BlockingScheduler 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(): 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): def start_check_results_job(sched):