Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions requirements.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
requests==2.19.1
progress==1.4
progressbar2==3.38.0
ipdb
60 changes: 38 additions & 22 deletions script.py
100644 → 100755
Original file line number Diff line number Diff line change
@@ -1,8 +1,11 @@
#!/usr/bin/python

import json
import time
import threading
from urllib import request
from progress.bar import Bar
import requests
import random
# from progress.bar import Bar
from datetime import datetime

filename = "lista_urls.txt"
Expand All @@ -14,44 +17,57 @@ def create_json(nomeJson, logger):
def execute_url_list(casa, logger, nomeJson):
try:
start = time.time()
result = request.urlopen(casa)
# print(casa)
result = requests.get(casa)
end = time.time()
if result.status != 200:
log = {'url':casa,'status':result.status,'tempo':end-start}
logger['erros'].append(log)
# import ipdb; ipdb.set_trace()
if not result.ok:
log = {'url':casa,'status':result.status_code,'latency':end-start}
logger['errors'].append(log)
# else:
# print('OK')
except Exception as e:
end = time.time()
log = {'url':casa, 'status':str(e),'tempo':end-start}
logger['erros'].append(log)
return (logger)
create_json(nomeJson, logger)
log = {'url':casa, 'status':str(e),'latency':end-start}
logger['errors'].append(log)
print('erro: %s' % casa)
# create_json(nomeJson, logger)
return logger

def threads(casas, logger, nomeJson):
bar = Bar('Loading', fill='@', suffix='%(percent)d%%',max= 1000)
# bar = Bar('Loading', fill='@', suffix='%(percent)d%%',max= 1000)

threads = [threading.Thread(target=execute_url_list,
args=(casa,logger, nomeJson, )) for casa in casas]

print("Start")
for thread in threads:
thread.start()
bar.next()
# bar.next()
for thread in threads:
thread.join()
bar.goto(1000)
# bar.goto(1000)


def main():
while(True):
logger = {'erros':[]}
nomeJson = "{}.json".format(str(datetime.now()))
with open(filename) as casas:
casas = list(casas)
casas = casas[1:]
threads(casas, logger, nomeJson)
print()
# while True:
logger = {'errors':[]}
nomeJson = "{}.json".format(datetime.now().strftime("%Y%m%dT%H%M"))
with open(filename) as f:
casas = f.read().split()
random.shuffle(casas)
# casas = casas[1:2]
start = 0
end = 100
while True:
threads(casas[start:end], logger, nomeJson)
print(end)
if end > len(casas):
break
start = end
end += 100
print("Done!")
time.sleep(300)
# time.sleep(300)



Expand Down