From 15df7d751e6cb59d3162c8fdc0faa983de67b73c Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 1 Mar 2017 20:10:07 +0100 Subject: log to file --- api.py | 15 +++++++++++++-- logs/.gitignore | 1 + 2 files changed, 14 insertions(+), 2 deletions(-) create mode 100644 logs/.gitignore diff --git a/api.py b/api.py index 541b386..880c474 100644 --- a/api.py +++ b/api.py @@ -19,7 +19,7 @@ class Worker(object): async def connect(self, **args): """Connect to database.""" - logging.info("connecting to database") + logging.warning("connecting to database") self._queue = joblib.joblib.JobQueue() await self._queue.connect(**args) await self._queue.setup() @@ -71,6 +71,8 @@ class Worker(object): await self._execute_job(jobid, payload, priority) await self._queue.finish(jobid) except crawler.ApiError as error: + logging.warning("%s: failed with %s", jobid, + error.args[0]) await self._queue.fail(jobid, error.args[0]) async def run(self): @@ -100,7 +102,16 @@ async def startup(): await worker.setup() await worker.start(2) -logging.basicConfig(level=logging.DEBUG) + +logging.basicConfig( + filename="logs/apigrabber.log", + filemode="a", + level=logging.DEBUG +) +console = logging.StreamHandler() +console.setLevel(logging.WARNING) +logging.getLogger("").addHandler(console) + loop = asyncio.get_event_loop() loop.run_until_complete(startup()) loop.run_forever() diff --git a/logs/.gitignore b/logs/.gitignore new file mode 100644 index 0000000..397b4a7 --- /dev/null +++ b/logs/.gitignore @@ -0,0 +1 @@ +*.log -- cgit v1.3.1