--- title: Official plugins description: Production-ready plugins developed and maintained by InfluxData. url: https://docs.influxdata.com/influxdb3/core/plugins/library/official/ estimated_tokens: 2081 product: InfluxDB 3 Core version: core publisher: InfluxData canonical: https://docs.influxdata.com/influxdb3/core/plugins/library/official/ date: '2026-07-11T10:53:18+00:00' lastmod: '2026-07-11T10:53:18+00:00' --- Official plugins developed and maintained by InfluxData for production use with InfluxDB 3 Core. ### [Amqp subscriber plugin](/influxdb3/core/plugins/library/official/amqp-subscriber/) Enables real-time ingestion of AMQP messages into InfluxDB 3. Subscribe to queues and transform messages into time-series data with support for JSON, Line Protocol, and custom text formats. ### [Basic transformation plugin](/influxdb3/core/plugins/library/official/basic-transformation/) Provides common data transformation functions for modifying and enriching time series data. ### [Bird data simulator plugin](/influxdb3/core/plugins/library/official/bird-data-simulator/) Generates synthetic bird tracking telemetry with persistent birds, ranges, simulated movement, speed, heading, and body temperature. Exposes only simple volume controls. ### [Chronos forecasting plugin](/influxdb3/core/plugins/library/official/chronos-forecasting/) Enables zero-shot time-series forecasting with Amazon Chronos models from HuggingFace, supporting scheduled batch forecasts and on-demand HTTP forecasts. ### [Downsampler plugin](/influxdb3/core/plugins/library/official/downsampler/) Automatically downsample and aggregate time series data at configurable intervals. ### [Earthquake sampler plugin](/influxdb3/core/plugins/library/official/earthquake-sampler/) Ingests USGS earthquake events on a schedule and writes normalized records for dashboards and alerting, with optional canonical quake-schema output. ### [Forecast error evaluator plugin](/influxdb3/core/plugins/library/official/forecast-error-evaluator/) Evaluate forecast accuracy by comparing predicted values against actual measurements. ### [Gapfill plugin](/influxdb3/core/plugins/library/official/gapfill/) Detects gaps in time series and fills them with imputed values using configurable interpolation methods, with optional fill marking and per-gap quality reports. Supports scheduled and HTTP backfill. ### [Geo enrichment plugin](/influxdb3/core/plugins/library/official/geo-enrichment/) Resolves lat/lon into location attributes—country and city, a zone or site you define, or a grid cell—merged into the source rows or written to a target table. HTTP endpoint backfills history. ### [Import plugin](/influxdb3/core/plugins/library/official/import/) Enables seamless data import from InfluxDB v1, v2, or v3 instances to InfluxDB 3 Core/Enterprise ### [InfluxDB to Iceberg plugin](/influxdb3/core/plugins/library/official/influxdb-to-iceberg/) Export time series data from InfluxDB to Apache Iceberg table format for data lake integration. ### [Kafka subscriber plugin](/influxdb3/core/plugins/library/official/kafka-subscriber/) Ingests Kafka messages into InfluxDB 3 with JSON, Line Protocol, text, Avro, JSON Schema, and Protobuf decoding, plus Schema Registry and local schema support. ### [MAD-based anomaly detection plugin](/influxdb3/core/plugins/library/official/mad-anomaly-detection/) Detect anomalies using Median Absolute Deviation (MAD) statistical analysis. ### [Mqtt subscriber plugin](/influxdb3/core/plugins/library/official/mqtt-subscriber/) Enables real-time ingestion of MQTT messages into InfluxDB 3. Subscribe to MQTT topics and transform messages into time-series data with support for JSON, Line Protocol, and custom text formats. ### [Notifier plugin](/influxdb3/core/plugins/library/official/notifier/) Send notifications and alerts to various channels including email, Slack, and webhooks. ### [NWS weather plugin](/influxdb3/core/plugins/library/official/nws-weather/) Provides real-time weather data from the National Weather Service API for demonstration and sample data purposes. Fetches live observations from multiple weather stations across the United States. ### [Opcua plugin](/influxdb3/core/plugins/library/official/opcua/) Enables periodic ingestion of OPC UA node values into InfluxDB 3. Connect to OPC UA servers and read current values with auto-discovery browse mode, data type detection, and namespace resolution. ### [Prophet forecasting plugin](/influxdb3/core/plugins/library/official/prophet-forecasting/) Generate time series forecasts using Facebook Prophet for predictive analytics. ### [Resampler plugin](/influxdb3/core/plugins/library/official/resampler/) Resamples time series with non-uniform timestamps onto a uniform time grid via configurable interpolation, or snaps timestamps to grid nodes keeping values and types unchanged. ### [River anomaly detector plugin](/influxdb3/core/plugins/library/official/river-anomaly-detector/) Detects time-series anomalies on writes using River ML models, combining rolling statistics with HalfSpaceTrees for per-series anomaly scoring and optional auto-tuning from River Auto Profiler output. ### [River auto profiler plugin](/influxdb3/core/plugins/library/official/river-auto-profiler/) Incrementally profiles time-series data with River ML streaming statistics and writes per-series recommendations for anomaly detection tuning, including thresholds, fading factors, and maturity. ### [River forecaster plugin](/influxdb3/core/plugins/library/official/river-forecaster/) Provides online time-series forecasting with River ML SNARIMAX models, learning from writes and producing scheduled multi-step forecasts with per-series model state and optional auto-horizon support. ### [Sagemaker plugin](/influxdb3/core/plugins/library/official/sagemaker/) Runs scheduled inference against Amazon SageMaker endpoints using recent InfluxDB 3 rows and writes prediction results back to InfluxDB. ### [Schema validator plugin](/influxdb3/core/plugins/library/official/schema-validator/) Validates incoming line protocol data against a JSON schema. ### [Signal filter plugin](/influxdb3/core/plugins/library/official/signal-filter/) Applies streaming digital IIR filters to numeric fields ### [Signal generator plugin](/influxdb3/core/plugins/library/official/signal-generator/) Generates scheduled, configurable waveform time-series data for demos, testing, dashboards, alerts, and plugin validation without external sources. Simulates outage gaps by default. ### [Simple data replicator plugin](/influxdb3/core/plugins/library/official/simple-data-replicator/) Replicates data between InfluxDB 3 instances over HTTP with table and field filtering, renaming, scheduler/write triggers, and compressed retry queue buffering. ### [State change plugin](/influxdb3/core/plugins/library/official/state-change/) Detect and track state changes in time series data for event monitoring. ### [Stateless ADTK detector plugin](/influxdb3/core/plugins/library/official/stateless-adtk-detector/) Perform anomaly detection using the Anomaly Detection Toolkit (ADTK) without maintaining state. ### [Stock plugin](/influxdb3/core/plugins/library/official/stock-plugin/) Tracks stock, ETF, and mutual fund portfolio values from Yahoo Finance with market-hours gating and rollups. ### [Synthefy forecasting plugin](/influxdb3/core/plugins/library/official/synthefy-forecasting/) Integrates Synthefy Forecasting API with InfluxDB 3 for on-demand time series forecasting via HTTP. Reads data from InfluxDB, generates forecasts with Synthefy models, and writes results back. ### [Synthefy nori regression plugin](/influxdb3/core/plugins/library/official/synthefy-nori-regression/) Predict a numeric InfluxDB 3 field from other columns with Synthefy’s Nori in-context tabular regression model, via the Synthefy inference gateway. Imputes rows where the target field is null. ### [System metrics plugin](/influxdb3/core/plugins/library/official/system-metrics/) Collects comprehensive system performance metrics including CPU, memory, disk, and network statistics. ### [Threshold deadman checks plugin](/influxdb3/core/plugins/library/official/threshold-deadman-checks/) Monitor data thresholds and detect missing data with deadman checks for alerting. ### [Valuecounter plugin](/influxdb3/core/plugins/library/official/valuecounter/) Counts unique field values from data-write or scheduled inputs and writes rollup measurements with per-value counts. [plugins](/influxdb3/core/tags/plugins/)[processing engine](/influxdb3/core/tags/processing-engine/)[python](/influxdb3/core/tags/python/)[official](/influxdb3/core/tags/official/)