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

use 25 segments

Browse Source
This commit is contained in:
PAN Lei
2024-04-26 12:27:13 +02:00
parent 0c6d276f82
commit d74904666c
3 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
queue_message/CookiesPublisher.py
+1
View File
@@ -7,6 +7,7 @@ REQUEST_DATA_QUEUE_TEST = 'REQUEST_DATA_TEST'
TEST_QUEUE = 'TEST_QUEUE' TEST_QUEUE = 'TEST_QUEUE'
SHARED_OBJECT = 'SHARED_OBJECT' SHARED_OBJECT = 'SHARED_OBJECT'
MORNING_DATA_CACHE = 'MORNING_DATA_CACHE' MORNING_DATA_CACHE = 'MORNING_DATA_CACHE'
MORNING_DATA_CACHE_2 = 'MORNING_DATA_CACHE_2'
MORNING_DATA_CACHE_BAK = 'MORNING_DATA_CACHE_BAK' MORNING_DATA_CACHE_BAK = 'MORNING_DATA_CACHE_BAK'
REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE' REQUEST_DATA_QUEUE_DE = 'REQUEST_DATA_DE'
REQUEST_DATA_OBJECT = 'REQUEST_DATA_OBJECT' REQUEST_DATA_OBJECT = 'REQUEST_DATA_OBJECT'
request_sender_test.py
+4 -3
View File
@@ -6,7 +6,8 @@ from threading import Thread
from db.mongo_manager import MONGO_STORE_MANAGER from db.mongo_manager import MONGO_STORE_MANAGER
from excel_reader import read_contacts from excel_reader import read_contacts
from models.contact_pojo import ContactPojo 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 queue_message.appointmentrequestsender import AppointmentRequestSender
from utiles import is_time_between from utiles import is_time_between
from utils.AppLogging import init_logger from utils.AppLogging import init_logger
@@ -78,11 +79,11 @@ 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, _sublist)) _thread1 = Thread(target=send_appointment_request, args=(MORNING_DATA_CACHE_2, _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=25, file_path='~/Desktop/24_04_to_test.xlsx') start_send_requests(thread_number=25, file_path='~/Desktop/contact_list_2024-04-17.xlsx')
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=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): def start_check_results_job(sched):