Bytewax Datadog

Datadog conectors for Bytewax.

This connector offers 1 source and 1 sink.

• LogSink - writes Datadog logs.
• LogSource - reads Datadog logs.

Installation

This package is available via PyPi as bytewax-datadog and can be installed via your package manager of choice.

Usage

Logs Source

from bytewax_datadog import LogSource
from bytewax.connectors.stdio import StdOutSink

import bytewax.operators as op
from bytewax.dataflow import Dataflow

flow = Dataflow("datadog_example")
flow_input = op.input("input", flow, LogSource.from_environment("example query"))
op.output("output", flow_input, StdOutSink())

Logs Sink

from bytewax_datadog import LogSink, CreateLogEntry
from bytewax.testing import TestingSource

import bytewax.operators as op
from bytewax.dataflow import Dataflow

flow = Dataflow("datadog_example")
flow_input = op.input("input", flow, TestingSource([
    CreateLogEntry(
        hostname="localhost",
        service="example-service",
        message="Hello World!",
    )
]))
op.output("output", flow_input, LogSink.from_environment("bytewax-datadog"))

License

Licensed under the MIT License