diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-01 20:10:07 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-01 20:10:07 +0100 |
| commit | 15df7d751e6cb59d3162c8fdc0faa983de67b73c (patch) | |
| tree | 482aa6d0bfb5d06340174f01a33857c79342ed08 /api.py | |
| parent | 8c58bedca6be1102264d1092feeaf5f4f41939b3 (diff) | |
| download | apigrabber-15df7d751e6cb59d3162c8fdc0faa983de67b73c.tar.gz apigrabber-15df7d751e6cb59d3162c8fdc0faa983de67b73c.zip | |
log to file
Diffstat (limited to 'api.py')
| -rw-r--r-- | api.py | 15 |
1 files changed, 13 insertions, 2 deletions
@@ -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() |
