Arvados™ Docs
WARNING - you are viewing the documentation for an old version of Arvados. For the latest version, click here.
  1. Overview
    1. SDK Reference
  2. Python
    1. Installation
    2. Examples
    3. PyDoc Reference
    4. Arvados FUSE driver
    5. Arvados CWL Runner
    6. Code cookbook
    7. Subscribing to database events
  3. CLI
    1. Installation
    2. Overview
    3. arv reference
    4. arv subcommands
  4. Go
    1. Installation
    2. Examples
  5. R
    1. R SDK Overview
    2. R Reference
  6. Ruby
    1. Installation
    2. Examples
  7. Java v2
    1. Installation
    2. Examples
    3. Javadoc Reference
  8. Java v1
    1. Installation
    2. Examples
  9. Perl
    1. Installation
    2. Examples

Subscribing to database events

Arvados applications can subscribe to a live event stream from the database. Events are described in the Log resource.

#!/usr/bin/env python3

import arvados
import arvados.events

# 'ev' is a dict containing the log table record describing the change.
def on_message(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")
ws = arvados.events.subscribe(api, [], on_message)
ws.run_forever()
Previous: Code cookbook Next: Installation

The content of this documentation is licensed under the Creative Commons Attribution-Share Alike 3.0 United States licence.
Code samples in this documentation are licensed under the Apache License, Version 2.0.