simon987/od-database
1
0
Fork 0
mirror of https://github.com/simon987/od-database.git synced 2025-04-19 18:36:44 +00:00
Code Issues Projects Releases Wiki Activity

Temporarily removed logger in async methods (https://stackoverflow.com/questions/37907350)

Browse Source
This commit is contained in:
Simon 2018-07-15 10:35:13 -04:00
parent 152a6f20fb
commit e18ded7ac1
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
crawl_server/run.py
View File

@ -3,6 +3,7 @@ import time
import config import config
tm = TaskManager(config.CRAWL_SERVER_PROCESSES) tm = TaskManager(config.CRAWL_SERVER_PROCESSES)
# TODO: On start, indicate that all tasks assigned to this crawler have been dropped
while True: while True:
time.sleep(1) time.sleep(1)

12
crawl_server/task_manager.py
View File

@ -57,7 +57,7 @@ class TaskManager:
r = requests.post(config.SERVER_URL + "/task/complete", data=payload, files=files) r = requests.post(config.SERVER_URL + "/task/complete", data=payload, files=files)
logger.info("RESPONSE: " + r.text) print("RESPONSE: " + r.text)
if os.path.exists(filename): if os.path.exists(filename):
os.remove(filename) os.remove(filename)
@ -89,7 +89,7 @@ class TaskManager:
result.start_time = datetime.utcnow().timestamp() result.start_time = datetime.utcnow().timestamp()
result.website_id = task.website_id result.website_id = task.website_id
logger.info("Starting task " + task.url) print("Starting task " + task.url)
crawler = RemoteDirectoryCrawler(task.url, config.CRAWL_SERVER_THREADS) crawler = RemoteDirectoryCrawler(task.url, config.CRAWL_SERVER_THREADS)
crawl_result = crawler.crawl_directory("./crawled/" + str(task.website_id) + ".json") crawl_result = crawler.crawl_directory("./crawled/" + str(task.website_id) + ".json")
@ -99,7 +99,7 @@ class TaskManager:
result.status_code = crawl_result.status_code result.status_code = crawl_result.status_code
result.end_time = datetime.utcnow().timestamp() result.end_time = datetime.utcnow().timestamp()
logger.info("End task " + task.url) print("End task " + task.url)
return result, current_tasks return result, current_tasks
@ -113,9 +113,9 @@ class TaskManager:
task_result, current_tasks = result task_result, current_tasks = result
logger.info("Task completed, sending result to server") print("Task completed, sending result to server")
logger.info("Status code: " + task_result.status_code) print("Status code: " + task_result.status_code)
logger.info("File count: " + str(task_result.file_count)) print("File count: " + str(task_result.file_count))
TaskManager.push_result(task_result) TaskManager.push_result(task_result)