use bak queue for url validation
This commit is contained in:
@@ -57,7 +57,7 @@ def send_appointment_request(message_queue_name, _contact_list, stop_at_hour=11,
|
|||||||
logger.info(_contact)
|
logger.info(_contact)
|
||||||
_cookiesPublisher = CookiesPublisher(queue_name=message_queue_name)
|
_cookiesPublisher = CookiesPublisher(queue_name=message_queue_name)
|
||||||
_cookiesPublisher.set_up_connection()
|
_cookiesPublisher.set_up_connection()
|
||||||
_backUp_cookiesPublisher = CookiesPublisher(queue_name=MORNING_DATA_CACHE_2)
|
_backUp_cookiesPublisher = CookiesPublisher(queue_name=MORNING_DATA_CACHE_BAK)
|
||||||
_backUp_cookiesPublisher.set_up_connection()
|
_backUp_cookiesPublisher.set_up_connection()
|
||||||
receiver = AppointmentRequestSender(sub_contact_list=_contact_list,
|
receiver = AppointmentRequestSender(sub_contact_list=_contact_list,
|
||||||
queue_name=message_queue_name,
|
queue_name=message_queue_name,
|
||||||
@@ -104,6 +104,6 @@ if __name__ == '__main__':
|
|||||||
# '~/Desktop/contact_list_2024-05-21.xlsx',
|
# '~/Desktop/contact_list_2024-05-21.xlsx',
|
||||||
# '~/Desktop/15_05_to_test.xlsx']
|
# '~/Desktop/15_05_to_test.xlsx']
|
||||||
# file_list = ['~/Desktop/15_05_to_test.xlsx', '~/Desktop/16_05_to_test.xlsx']
|
# file_list = ['~/Desktop/15_05_to_test.xlsx', '~/Desktop/16_05_to_test.xlsx']
|
||||||
file_list = ['~/Desktop/contact_list_all.xlsx']
|
file_list = ['~/Desktop/contact_list_2024-08-22_aol.xlsx']
|
||||||
send_request_for_file_list(file_list=file_list, thread_number=1,
|
send_request_for_file_list(file_list=file_list, thread_number=5,
|
||||||
data_queue_name=MORNING_DATA_CACHE_2, stop_at_hour=17, stop_at_mins=30)
|
data_queue_name=MORNING_DATA_CACHE_2, stop_at_hour=18, stop_at_mins=30)
|
||||||
|
|||||||
@@ -215,8 +215,8 @@ def validate_all_links():
|
|||||||
divided = 3
|
divided = 3
|
||||||
default_segment_number = 20
|
default_segment_number = 20
|
||||||
_first_25_percent_links = all_link_list[0:(int(len(all_link_list) / divided))]
|
_first_25_percent_links = all_link_list[0:(int(len(all_link_list) / divided))]
|
||||||
_queue_name = MORNING_DATA_CACHE_2
|
# _queue_name = MORNING_DATA_CACHE_2
|
||||||
# _queue_name = MORNING_DATA_CACHE_BAK
|
_queue_name = MORNING_DATA_CACHE_BAK
|
||||||
if len(all_link_list) > divided * default_segment_number:
|
if len(all_link_list) > divided * default_segment_number:
|
||||||
_segment_number = default_segment_number
|
_segment_number = default_segment_number
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user