InfluxDB 3

Use the @bijection/connectors/influxdb entrypoint to declare InfluxDB 3 resources.

Availability

This page describes the pinned source package. Published availability is unestablished for this artifact. Source build and package availability.

Resources and modes

Resource	Mode	Description
Measurement	`timeRange`	SQL time range

Declare a resource in application code, then bind deployment-specific settings and credentials. See typed resources, connections and source inspection.

Measurement

timeRange: SQL time range

The following example matches configuration standard.

import { influxdb } from "@bijection/connectors/influxdb";
import { v } from "bijection/values";

export const cpu = influxdb.measurement.timeRange({
  measurement: "cpu",
  tags: ["host", "region"],
  schema: { usage: v.optional(v.number()) },
});

Inferred record types

{
  "usage": number | undefined;
  "_time": any;
  "_key": any;
  "host": any;
  "region": any;
}

Configuration: standard

Case: influxdb/measurement/timeRange/standard. Connection and resource configuration are declared by this exact case. Credential kind: influxdb. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`url`	string	Yes	Shared connection
`database`	string	Yes	Resource binding

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "influxdb",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "influxdb",
    "connection_fields": [
      "url"
    ],
    "selection_field": "database",
    "address": {
      "kind": "setup",
      "field": "url"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "url": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "database": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "records": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "400": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "401": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "403": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "404": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "500": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        },
        "503": {
          "placement": "retained_bytes",
          "interpretation": "opaque",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange records",
          "limitBytes": null
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "records": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "400": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "401": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "403": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "404": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "500": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              },
              "503": {
                "placement": "retained_bytes",
                "interpretation": "opaque",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange records",
                "limitBytes": null
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	Native test: integrations/acquisition/acquisition_windows_preserve_sequences_and_restart_fences_old_work (shared_engine)	Execution result unavailable
watermark-boundary-replay	{“kind”:“collection”,“name”:“records”}	Fixture: ./src/connectors/influxdb/fixtures/boundary-replay.json	passed (2026-10-24T21:36:12.064Z)
watermark-empty-page-ends	{“kind”:“collection”,“name”:“records”}	Fixture: ./src/connectors/influxdb/fixtures/empty-page-ends.json	passed (2026-10-24T21:36:12.065Z)
identity-account	{“kind”:“connection”}	Fixture: ./src/connectors/influxdb/fixtures/identity.json	passed (2026-10-24T21:36:12.065Z)

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Provider guidance

Compiled declaration examples and configuration details are published in the connector reference. Bind the server origin (url) on the connection and the database (database) on the resource. Authenticate with an InfluxDB 3 token as a bearer (influxdb.credential(name)).

Mechanism. InfluxDB 3 Core and Enterprise SQL through POST /api/v3/query_sql with format: "json". InfluxDB 2’s Flux answers annotated CSV, which no host codec decodes; Cloud Serverless and Dedicated serve SQL over Arrow Flight only, and their InfluxQL rows are positional and untyped.
Identity of a point. The compound of every declared tag and the point time; points missing a declared tag are not read. Writing the same series and time again replaces its fields.
Time range. time >= $since AND time < now() - INTERVAL '<settleMs>', ordered by time and tags, with time rendered as fixed-width nanosecond UTC text. The server holds back the settle window (default one minute), which is the declared observation lag. The host keeps the largest rendered time a page carried; the inclusive bound re-reads it.
Late writes. Point time is the writer’s timestamp. A point backfilled behind the derived maximum, or an overwrite of a point already read, is not observed. The version is the point time, so a re-read boundary point whose fields changed is deduplicated.
Deletions. Not observed.

Not established: no request has reached InfluxDB; to_char rendering, params binding and the bare-array response root are taken from documentation only.

Provider references

Provider references and prerequisites are maintained in the connector guidance above. No separate provider-documentation review date is recorded.

Source and evidence

Canonical connector source, native analysis and check receipts. Connector artifact: 905888ea276a2a28e36981a79e8142b2547ea451c3e63162cb6915ad4a7d1305. The resource declaration examples above are compiled and compared with exact catalog declarations. Recorded checks apply only to their source, declaration and runtime identities. Configure a connection and inspect its status to establish deployment-specific readiness.

Get Started

Use-case atlas

Platform

Data and Operations

Guides

Client Libraries

Tools

API Reference

Availability

Resources and modes

Measurement

timeRange: SQL time range

Configuration: standard

Provider guidance

Provider references

Source and evidence

​Availability

​Resources and modes

​Measurement

​timeRange: SQL time range

​Configuration: standard

​Provider guidance

​Provider references

​Source and evidence

Availability

Resources and modes

Measurement

timeRange: SQL time range

Configuration: standard

Provider guidance

Provider references

Source and evidence