Prometheus (dagster-prometheus)

dagster_prometheus.PrometheusResource ResourceDefinition

beta

This API is currently in beta, and may have breaking changes in minor version releases, with behavior changes in patch releases.

This resource is used to send metrics to a Prometheus Pushgateway.

Example:

from dagster_prometheus import PrometheusResource
from dagster import Definitions, job, op

@op
def example_prometheus_op(prometheus: PrometheusResource):
    prometheus.push_to_gateway(job="my_job")

@job
def my_job():
    example_prometheus_op()

defs = Definitions(
    jobs=[my_job],
    resources={"prometheus": PrometheusResource(gateway="http://pushgateway.local")},
)

class dagster_prometheus.resources.PrometheusClient: Integrates with Prometheus via the prometheus_client library.

Legacy

dagster_prometheus.prometheus_resource ResourceDefinition: beta
This API is currently in beta, and may have breaking changes in minor version releases, with behavior changes in patch releases.

Legacy​

Legacy