summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-03-01 20:10:07 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2017-03-01 20:10:07 +0100
commit15df7d751e6cb59d3162c8fdc0faa983de67b73c (patch)
tree482aa6d0bfb5d06340174f01a33857c79342ed08
parent8c58bedca6be1102264d1092feeaf5f4f41939b3 (diff)
downloadapigrabber-15df7d751e6cb59d3162c8fdc0faa983de67b73c.tar.gz
apigrabber-15df7d751e6cb59d3162c8fdc0faa983de67b73c.zip
log to file
-rw-r--r--api.py15
-rw-r--r--logs/.gitignore1
2 files changed, 14 insertions, 2 deletions
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