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

Merge branch 'feature/data_impulse'

Browse Source
This commit is contained in:
PAN Lei
2024-05-15 11:58:51 +02:00
parent 35ec23fbaa 67d6633951
commit 86cef6d85a
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
request_sender_test.py
+4 -3
View File
@@ -67,7 +67,7 @@ def send_appointment_request(message_queue_name, _contact_list):
receiver.run() receiver.run()
def start_send_requests(thread_number, file_path): def start_send_requests(thread_number, file_path, data_queue_name=MORNING_DATA_CACHE):
print("start send requests") print("start send requests")
contacts_file_path = file_path contacts_file_path = file_path
_contact_list = read_contacts(contacts_file_path) _contact_list = read_contacts(contacts_file_path)
@@ -79,11 +79,12 @@ def start_send_requests(thread_number, file_path):
logger.info("segment is {}".format(i)) logger.info("segment is {}".format(i))
_step = int(len(_contact_list_to_book) / _segment_number) _step = int(len(_contact_list_to_book) / _segment_number)
_sublist = _contact_list_to_book[i * _step:_step * (i + 1)] _sublist = _contact_list_to_book[i * _step:_step * (i + 1)]
_thread1 = Thread(target=send_appointment_request, args=(MORNING_DATA_CACHE_2, _sublist)) _thread1 = Thread(target=send_appointment_request, args=(data_queue_name, _sublist))
last_thread = _thread1 last_thread = _thread1
_thread1.start() _thread1.start()
last_thread.join() last_thread.join()
if __name__ == '__main__': if __name__ == '__main__':
start_send_requests(thread_number=28, file_path='~/Desktop/contact_list_2024-05-10.xlsx') start_send_requests(thread_number=30, file_path='~/Desktop/contact_list_2024-05-14.xlsx',
data_queue_name=MORNING_DATA_CACHE_2)
scheduler_test.py
+1 -1
View File
@@ -5,7 +5,7 @@ from request_sender_test import start_send_requests
def start_book_appointment(): def start_book_appointment():
start_send_requests(thread_number=28, file_path='~/Desktop/contact_list_2024-05-10.xlsx') start_send_requests(thread_number=31, file_path='~/Desktop/contact_list_2024-05-14.xlsx')
def start_check_results_job(sched): def start_check_results_job(sched):