support tags.js version 4.25.1
This commit is contained in:
+1
-1
@@ -71,7 +71,7 @@ def send_appointment_request(message_queue_name, _contact_list):
|
|||||||
|
|
||||||
def start_send_requests():
|
def start_send_requests():
|
||||||
print("start send requests")
|
print("start send requests")
|
||||||
contacts_file_path = '~/Desktop/contact_list_2024-04-06-2.xlsx'
|
contacts_file_path = '~/Desktop/contact_list_2024-04-16_2.xlsx'
|
||||||
_contact_list = read_contacts(contacts_file_path)
|
_contact_list = read_contacts(contacts_file_path)
|
||||||
_contact_list_to_book = filter_contacts(_contact_list)
|
_contact_list_to_book = filter_contacts(_contact_list)
|
||||||
_segment_number = 10
|
_segment_number = 10
|
||||||
|
|||||||
@@ -0,0 +1,30 @@
|
|||||||
|
from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
|
||||||
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
||||||
|
|
||||||
|
from request_sender_test import start_send_requests
|
||||||
|
|
||||||
|
|
||||||
|
def start_book_appointment():
|
||||||
|
start_send_requests()
|
||||||
|
|
||||||
|
|
||||||
|
def start_check_results_job(sched):
|
||||||
|
sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='10',
|
||||||
|
minute='30',
|
||||||
|
misfire_grace_time=10,
|
||||||
|
second='0', timezone='Europe/Paris', max_instances=1, args=[])
|
||||||
|
|
||||||
|
|
||||||
|
def config_and_start_jobs():
|
||||||
|
executors = {
|
||||||
|
'default': ThreadPoolExecutor(30),
|
||||||
|
'processpool': ProcessPoolExecutor(12)
|
||||||
|
}
|
||||||
|
sched = BlockingScheduler(executors=executors)
|
||||||
|
start_check_results_job(sched)
|
||||||
|
sched.print_jobs()
|
||||||
|
sched.start()
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
config_and_start_jobs()
|
||||||
Reference in New Issue
Block a user