try to add model to link validator
This commit is contained in:
@@ -104,8 +104,8 @@ def check_all_need_to_check_emails():
|
||||
check_mail(_mail)
|
||||
time.sleep(2)
|
||||
|
||||
_mail_list = [MailAddress("saigecong1990@pissmail.com", "cvExXKOP8oY1D@")]
|
||||
find_links_to_validate_from_mail_list(_mail_list, logger)
|
||||
# _mail_list = [MailAddress("saigecong1990@pissmail.com", "cvExXKOP8oY1D@")]
|
||||
# find_links_to_validate_from_mail_list(_mail_list, logger)
|
||||
is_checking = False
|
||||
|
||||
|
||||
@@ -117,8 +117,8 @@ def try_to_check_all_mails():
|
||||
if "outlook.com" in _mail or "hotmail.com" in _mail:
|
||||
check_appointment_link_mail(_mail)
|
||||
time.sleep(2)
|
||||
_mail_list = [MailAddress("saigecong1990@pissmail.com", "cvExXKOP8oY1D@")]
|
||||
find_links_to_validate_from_mail_list(_mail_list, logger)
|
||||
# _mail_list = [MailAddress("saigecong1990@pissmail.com", "cvExXKOP8oY1D@")]
|
||||
# find_links_to_validate_from_mail_list(_mail_list, logger)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
|
||||
@@ -74,8 +74,8 @@ class ProxyManager:
|
||||
|
||||
def get_link_validate_proxy(self, links_to_validate: list) -> list:
|
||||
# return [FR_PROXY_RES_PARIS_OXY]
|
||||
# return [FR_MOBILE_ANY_IP_ROTATING]
|
||||
return [FR_PROXY_RES_OXY]
|
||||
return [FR_MOBILE_ANY_IP_ROTATING]
|
||||
# return [FR_PROXY_RES_OXY]
|
||||
# if len(links_to_validate) > 15:
|
||||
# return [FR_PROXY_RES_OXY, FR_PROXY_MOB_OXY, FR_PROXY_ASOCK_RES_2, FR_DATA_IMPULSE_RES]
|
||||
# # return [FR_PROXY_RES_OXY, FR_PROXY_ASOCK_RES_2, FR_DATA_IMPULSE_RES, FR_ASOCKS_MOBILE_PROXY]
|
||||
|
||||
@@ -37,4 +37,8 @@ class CookiesPublisher:
|
||||
))
|
||||
|
||||
def message_count(self):
|
||||
# try:
|
||||
return self.channel.queue_declare(queue=self.to_queue, durable=True).method.message_count
|
||||
# except Exception as error:
|
||||
# print(error)
|
||||
# return 0
|
||||
|
||||
@@ -67,7 +67,7 @@ def is_open():
|
||||
|
||||
def check_ms_mails(_mail_list_filtered):
|
||||
print("check_ms_mails() called.")
|
||||
check_all_need_to_check_emails()
|
||||
# check_all_need_to_check_emails()
|
||||
# for _mail in _mail_list_filtered:
|
||||
# if "outlook.com" in _mail.mail or "hotmail.com" in _mail.mail:
|
||||
# check_mail(_mail.mail)
|
||||
|
||||
@@ -100,13 +100,13 @@ if __name__ == '__main__':
|
||||
# file_list = ['~/Desktop/contact_list_2024-05-23.xlsx',
|
||||
# '~/Desktop/contact_list_2024-05-21.xlsx',
|
||||
# '~/Desktop/15_05_to_test.xlsx']
|
||||
# file_list = ['~/Desktop/15_05_to_test.xlsx', '~/Desktop/16_05_to_test.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-07-15.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-07-28.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-06-23.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-03-11.xlsx']
|
||||
file_list = ['~/Desktop/contact_list_2025-05-21.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-08-14.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-05-16.xlsx']
|
||||
file_list = ['~/Desktop/contact_list_2025-09-08.xlsx']
|
||||
# file_list = ['~/Desktop/real_name_contacts_100_aol_17_04.xlsx']
|
||||
# file_list = ['~/Desktop/contact_list_2025-08-18_no_ms.xlsx']
|
||||
# file_list = ['~/Desktop/real_name_contacts_100_27_06.xlsx']
|
||||
send_request_for_file_list(file_list=file_list, thread_number=10,
|
||||
data_queue_name=MORNING_DATA_CACHE, stop_at_hour=19, stop_at_mins=50)
|
||||
|
||||
+5
-5
@@ -6,14 +6,14 @@ from request_sender_test import send_request_for_file_list
|
||||
|
||||
|
||||
def start_book_appointment():
|
||||
file_list = ['~/Desktop/contact_list_2025-08-18.xlsx']
|
||||
send_request_for_file_list(file_list=file_list, thread_number=10,
|
||||
data_queue_name=MORNING_DATA_CACHE, stop_at_hour=14, stop_at_mins=20)
|
||||
file_list = ['~/Desktop/contact_list_2025-09-08.xlsx']
|
||||
send_request_for_file_list(file_list=file_list, thread_number=20,
|
||||
data_queue_name=MORNING_DATA_CACHE, stop_at_hour=18, stop_at_mins=20)
|
||||
|
||||
|
||||
def start_check_results_job(sched):
|
||||
sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='13',
|
||||
minute='00',
|
||||
sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='14',
|
||||
minute='01',
|
||||
misfire_grace_time=10,
|
||||
second='10', timezone='Europe/Paris', max_instances=1, args=[])
|
||||
|
||||
|
||||
+1
-1
@@ -6,7 +6,7 @@ from request_sender_test import send_request_for_file_list
|
||||
|
||||
|
||||
def start_book_appointment():
|
||||
file_list = ['~/Desktop/contact_list_2025-08-18.xlsx']
|
||||
file_list = ['~/Desktop/contact_list_2025-09-08.xlsx']
|
||||
send_request_for_file_list(file_list=file_list, thread_number=60,
|
||||
data_queue_name=MORNING_DATA_CACHE, stop_at_hour=11, stop_at_mins=10)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user