AIL/ail-framework
7
0
Fork 0
mirror of https://github.com/ail-project/ail-framework.git synced 2024-11-10 08:38:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: [Crawler] save domain to crawl on splash error

Browse source
This commit is contained in:
Terrtia 2018-09-18 16:20:13 +02:00
parent ce63d81878
commit 5b31b6e853
No known key found for this signature in database
GPG key ID: 1E1B1F50D84613D0
1 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
bin/Crawler.py
View file

@ -18,7 +18,7 @@ from pubsublogger import publisher
def signal_handler(sig, frame): def signal_handler(sig, frame):
sys.exit(0) sys.exit(0)
def crawl_onion(url, domain, date, date_month): def crawl_onion(url, domain, date, date_month, message):
#if not r_onion.sismember('full_onion_up', domain) and not r_onion.sismember('onion_down:'+date , domain): #if not r_onion.sismember('full_onion_up', domain) and not r_onion.sismember('onion_down:'+date , domain):
super_father = r_serv_metadata.hget('paste_metadata:'+paste, 'super_father') super_father = r_serv_metadata.hget('paste_metadata:'+paste, 'super_father')
@ -29,6 +29,12 @@ def crawl_onion(url, domain, date, date_month):
r = requests.get(splash_url , timeout=30.0) r = requests.get(splash_url , timeout=30.0)
except Exception: except Exception:
## FIXME: # TODO: relaunch docker or send error message ## FIXME: # TODO: relaunch docker or send error message
# send this msg back in the queue
if not r_onion.sismember('{}_domain_crawler_queue'.format(type_hidden_service), domain):
r_onion.sadd('{}_domain_crawler_queue'.format(type_hidden_service), domain)
r_onion.sadd('{}_crawler_queue'.format(type_hidden_service), message)
print('--------------------------------------') print('--------------------------------------')
print(' DOCKER SPLASH DOWN') print(' DOCKER SPLASH DOWN')
exit(0) exit(0)
@ -171,11 +177,11 @@ if __name__ == '__main__':
if not r_onion.sismember('month_{}_up:{}'.format(type_hidden_service, date_month), domain) and not r_onion.sismember('{}_down:{}'.format(type_hidden_service, date), domain): if not r_onion.sismember('month_{}_up:{}'.format(type_hidden_service, date_month), domain) and not r_onion.sismember('{}_down:{}'.format(type_hidden_service, date), domain):
crawl_onion(url, domain, date, date_month) crawl_onion(url, domain, date, date_month, message)
if url != domain_url: if url != domain_url:
print(url) print(url)
print(domain_url) print(domain_url)
crawl_onion(domain_url, domain, date, date_month) crawl_onion(domain_url, domain, date, date_month, message)
# save down onion # save down onion
if not r_onion.sismember('{}_up:{}'.format(type_hidden_service, date), domain): if not r_onion.sismember('{}_up:{}'.format(type_hidden_service, date), domain):