Logging tweaks.

fedmsg.d/example-config.py

@@ -11,4 +11,13 @@
             "tcp://127.0.0.1:99887",
         ],
     },
+    'logging': {
+        'loggers': {
+            'summershum': {
+                'handlers': ['console'],
+                'level': 'INFO',
+                'propagate': False
+            },
+        },
+    },
 }

summershum/consumer.py

@@ -1,14 +1,21 @@
 import fedmsg.consumers
 import summershum.utils
 
+import logging
+log = logging.getLogger("summershum")
+
 
 class SummerShumConsumer(fedmsg.consumers.FedmsgConsumer):
     topic = 'org.fedoraproject.prod.git.lookaside.new'
     config_key = 'summershum.enabled'
 
+    def __init__(self, *args, **kwargs):
+        super(SummerShumConsumer, self).__init__(*args, **kwargs)
+        log.info("Ready for ingestion")
+
     def consume(self, msg):
         msg = msg['body']['msg']
-        self.log.info("Ingesting %r" % msg.get('filename'))
+        log.info("Ingesting %r" % msg.get('filename'))
         fedmsg.publish(
             topic='ingest.start',
             msg=dict(original=msg),
@@ -17,7 +24,7 @@ def consume(self, msg):
             summershum.utils.download_lookaside(msg)
             summershum.utils.get_sha1sum(msg)
         except Exception as e:
-            self.log.error("Failed to ingest %r %r" % (msg.get('filename'), e))
+            log.error("Failed to ingest %r %r" % (msg.get('filename'), e))
             fedmsg.publish(
                 topic='ingest.fail',
                 msg=dict(
@@ -26,7 +33,7 @@ def consume(self, msg):
                 ),
             )
         else:
-            self.log.info("Done ingesting %r" % msg.get('filename'))
+            log.info("Done ingesting %r" % msg.get('filename'))
             fedmsg.publish(
                 topic='ingest.complete',
                 msg=dict(original=msg),