Skip to main content

Event-driven action framework for DataHub — trigger automations and workflows in response to real-time metadata changes

Project description

DataHub Actions

Event-driven automation for DataHub — react to metadata changes in real time and trigger workflows, notifications, or custom logic.

What you can do

  • Listen to metadata change events as they happen (entity updates, tag additions, ownership changes, etc.)
  • Filter events to only act on what matters to you
  • Chain transformers to enrich or reshape events before they reach your action
  • Build custom actions — call APIs, send Slack alerts, trigger pipelines, sync to external systems
  • Run multiple pipelines in a single process

Installation

pip install acryl-datahub acryl-datahub-actions
datahub actions version

Quickstart

Define an action pipeline in YAML and run it:

# my_action.yml
name: tag_watcher

source:
  type: kafka
  config:
    connection:
      bootstrap: localhost:9092
      schema_registry_url: http://localhost:8081

filter:
  event_type: EntityChangeEvent_v1
  event:
    category: TAG
    operation: ADD

action:
  type: hello_world
datahub actions -c my_action.yml

Key concepts

Concept Description
Source Where events come from (currently: Kafka)
Filter Narrow down which events trigger the action
Transformer Optionally reshape or enrich events
Action What to do — call an API, send a message, run code

Supported events

  • EntityChangeEvent_v1 — fired when an entity's metadata changes (tags, owners, terms, etc.)
  • MetadataChangeLogEvent_v1 — low-level log of every aspect write

Links

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

acryl_datahub_actions-1.6.0.10rc1.tar.gz (76.7 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

acryl_datahub_actions-1.6.0.10rc1-py3-none-any.whl (121.9 kB view details)

Uploaded Python 3

File details

Details for the file acryl_datahub_actions-1.6.0.10rc1.tar.gz.

File metadata

File hashes

Hashes for acryl_datahub_actions-1.6.0.10rc1.tar.gz
Algorithm Hash digest
SHA256 0029f452c4530c062328f1aec8c8e9f68a2a18f957cd59b3b9186c6ffc3cea6d
MD5 93be13ba0851537b347621dedca4d9a3
BLAKE2b-256 6108dab320dc703293770395a8d065bfd938879c27830c65e85a9292ad3d4491

See more details on using hashes here.

File details

Details for the file acryl_datahub_actions-1.6.0.10rc1-py3-none-any.whl.

File metadata

File hashes

Hashes for acryl_datahub_actions-1.6.0.10rc1-py3-none-any.whl
Algorithm Hash digest
SHA256 dded99707bd91c5b178299ae6b8e2a2af0f71f5102c76b9518cee04446540d48
MD5 7c94a3b925201636e7585176e46c7fab
BLAKE2b-256 0b4e42d0e074d0b1c4424afc7f650518d047ece1e759ea119d3839671e6ad730

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page