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.10rc3.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.10rc3-py3-none-any.whl (121.9 kB view details)

Uploaded Python 3

File details

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

File metadata

File hashes

Hashes for acryl_datahub_actions-1.6.0.10rc3.tar.gz
Algorithm Hash digest
SHA256 de41556249dcb8d9858e8b05000d4070d5317c4f6d94dc32622951c7c3957b6f
MD5 aa46bff78d810920f069e035abb9c9a7
BLAKE2b-256 b4316dd50624d8f8c5d4630e74da51a641fb4e303e43a0f88787d560b781310a

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for acryl_datahub_actions-1.6.0.10rc3-py3-none-any.whl
Algorithm Hash digest
SHA256 1f77bd66c62d648aeb7ee158e409a455f8283494c37d7e5b7f230e419c817fc9
MD5 9a4d0d6b4707069d14a10b47efec4bce
BLAKE2b-256 caa352b5f1e19ec2104e7eecfa0ea1bab9783845909fc25678d0419da98fae1d

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