use CSV as default output format

mgship/cli.py

@@ -4,14 +4,14 @@
 import click
 
 from mgship import mgship
-from mgship.destination import console
+from mgship.destination import csv
 
 
 @click.command()
 def main(args=None):
     """Console script for mgship"""
 
-    mgship.Archive(console.Destination()).ship()
+    mgship.Archive(csv.Destination()).ship()
 
 
 if __name__ == "__main__":

mgship/destination/csv.py

@@ -0,0 +1,31 @@
+"""Print events to the console as CSV."""
+from __future__ import absolute_import
+import sys
+import csv
+
+
+from contextlib import contextmanager
+
+__all__ = ['Destination']
+
+
+def print_events():
+    eid = None
+    writer = csv.writer(sys.stdout)
+    while True:
+        event = yield eid
+        envelope = event.get('envelope', {})
+        writer.writerow([
+            ','.join(event.get('tags', [])),
+            envelope.get('sender', ''),
+            envelope.get('targets', ''),
+            event.get('event', ''),
+            event.get('timestamp', '')])
+
+
+def make_sink():
+    sink = print_events()
+    next(sink)
+    yield sink
+
+Destination = contextmanager(make_sink)

mgship/destination/json.py

@@ -0,0 +1,24 @@
+"""Print events to the console as JSON."""
+from __future__ import absolute_import
+import sys
+import json
+
+
+from contextlib import contextmanager
+
+__all__ = ['Destination']
+
+
+def print_events():
+    eid = None
+    while True:
+        event = yield eid
+        print json.dumps(event)
+
+
+def make_sink():
+    sink = print_events()
+    next(sink)
+    yield sink
+
+Destination = contextmanager(make_sink)