#!/usr/bin/env python
+{% comment %}
+Copyright (C) The Arvados Authors. All rights reserved.
+
+SPDX-License-Identifier: CC-BY-SA-3.0
+{% endcomment %}
import arvados
import arvados.events
-import json
# 'ev' is a dict containing the log table record describing the change.
def on_message(ev):
- # Your code here.
- print json.dumps(ev)
-
+ if ev.get("event_type") == "create" and ev.get("object_kind") == "arvados#collection":
+ print "A new collection was created: %s" % ev["object_uuid"]
-api = arvados.api('v1', cache=False)
+api = arvados.api("v1")
ws = arvados.events.subscribe(api, [], on_message)
ws.run_forever()