Prometheus — `prometheus`

Takes instant-query snapshots of PromQL expressions on every poll tick — each query becomes a stream of metric events, joinable with logs and deploys on the same key. Supports discovery: given a url, it lists the metrics the server carries and proposes queries.

Prerequisites: a reachable Prometheus server (its base URL, e.g. http://localhost:9090).

Set up

Agent

Ask a connected agent:

Use navflow to ingest the 5xx rate per service from the Prometheus at localhost:9090.

The agent calls discover_source (introspects the server’s metrics, proposes queries), test_source (dry-run — evaluates the queries once), then create_source.

Console

Sources → Add source → prometheus. Set:

url: the Prometheus base URL
queries: one row per PromQL expression — the form’s row builder maps each to an event_type, field, and text

Discover lists the server’s metrics to pick from. Set a label with primary: true (e.g. service) so series correlate by service; default_key covers series that carry no key label.

YAML / API


- name: metrics
  connector: prometheus
  poll: 10s
  config:
    url: http://localhost:9090
    default_key: api
    queries:
      - promql: 'sum(rate(http_requests_total{status=~"5.."}[1m])) by (service)'
        event_type: 5xx_rate
        field: rate_5xx
        text: '5xx {service}={val}/s'
    labels:
      - { name: service, field: service, primary: true }

Or POST /api/sources with the same object. The demo catalog has a fuller example (five queries over one server).

Configuration

field	type	description
`url`*	string	Prometheus base URL, e.g. `http://localhost:9090`
`default_key`	string	entity key for series that carry no key label (default `unknown`)
`queries`*	list	metrics to ingest — each a PromQL query mapped into the envelope

Each queries entry:

field	type	description
`promql`*	string	PromQL (a bare metric name = raw, lossless ingest)
`event_type`	string	event type for this query’s events (default `metric`)
`field`	string	`fields.<name>` the numeric value is stored under (default `value`)
`text`	string	rendered line template (default `{key} {field}={val}`)
`key_label`	string	series label to read the entity key from, e.g. `service`

Verify

Open the source in the console: Recent events shows one event per series per poll. Watch a metric move in Explore by picking the entity the series is keyed on.

Prometheus — prometheus