文档文档

Microsoft Fabric 输出插件

此插件将指标写入Fabric EventhouseFabric Eventstream,这些是Microsoft Fabric 中的实时智能的组件。

实时智能是 Microsoft Fabric 中的一项 SaaS 服务,可让您提取见解并可视化动态数据。它为事件驱动的场景、流数据和数据日志提供端到端解决方案。

引入于: Telegraf v1.35.0 标签: datastore 操作系统支持: all

全局配置选项

插件支持其他全局和插件配置设置,用于修改指标、标签和字段,创建别名以及配置插件顺序等任务。更多详情请参阅 CONFIGURATION.md

配置

# Sends metrics to Microsoft Fabric
[[outputs.microsoft_fabric]]
  ## The URI property of the resource on Microsoft Fabric
  connection_string = "https://trd-abcd.xx.kusto.fabric.microsoft.com;Database=kusto_eh;Table Name=telegraf_dump;Key=value"

  ## Client timeout
  # timeout = "30s"

连接字符串

connection_string 提供插件连接到 Fabric 服务终结点所需的信息。它是由名称-值参数对组成的以分号分隔的列表,前面可以选择性地加上单个 URI。此设置特定于您使用的终结点类型。以下各部分将详细介绍每种类型的必需名称-值对和可用名称-值对。

EventHouse

此插件允许您利用 Microsoft Fabric 的功能来存储和分析您的 Telegraf 指标。Eventhouse 是一个高性能、可扩展的数据存储,专为实时分析而设计。它允许您以低延迟摄取、存储和查询大量数据。有关更多信息,请访问 Eventhouse 文档

下表列出了连接字符串中可能包含的所有属性,并为每个属性提供了别名。

属性名别名描述
用于跟踪的客户端版本用于跟踪客户端版本时使用的属性。
数据源Addr, Address, Network Address, Server指定 Eventhouse 服务终结点的 URI。例如,https://mycluster.fabric.windows.net
初始目录数据库默认数据库名称。例如,MyDatabase
摄取类型IngestionType值可以设置为 managed 以实现流式摄取并回退到批量摄取,或者设置为 queued 方法以排队指标并按顺序处理。
表名TableName存储所有指标的单个表的名称;仅当 metrics_grouping_typesingletable 时才需要。
创建表CreateTables如果为 true(默认值),则创建表和相关的映射。否则,将跳过表和映射的创建。这对于以可能的最低权限(表摄取者角色)运行 Telegraf 非常有用。
指标分组类型MetricsGroupingType将指标推送到 Eventhouse 时使用的指标分组类型,可以是 tablepermetricsingletable。默认值为“tablepermetric”,即每个不同指标一个表。

指标分组

指标可以通过两种方式进行分组以发送到 Eventhouse。要指定插件应使用哪种指标分组类型,应在连接字符串中为 Metrics Grouping Type 指定相应的值。如果未提供值,则默认情况下,指标将使用 tablepermetric 进行分组。

TablePerMetric

插件将按指标名称对指标进行分组,并将每个指标组发送到一个 Eventhouse KQL DB 表。如果表不存在,插件将创建该表;如果表存在,插件将尝试将 Telegraf 指标架构合并到现有表中。有关合并过程的更多信息,请参阅 .create-merge 文档

表名将与指标名称匹配。如果您计划为指标名称添加前缀,则指标名称必须符合 Eventhouse KQL DB 表命名约束。

SingleTable

插件将把所有接收到的指标发送到一个 Eventhouse KQL DB 表。表名必须通过 connection_string 中的 table_name 参数提供。如果表不存在,插件将创建该表;如果表存在,插件将尝试将 Telegraf 指标架构合并到现有表中。有关合并过程的更多信息,请参阅 .create-merge 文档

表架构

Eventhouse 表的架构将与指标的结构匹配。插件生成的相应命令将如下所示:

.create-merge table ['table-name']  (['fields']:dynamic, ['name']:string, ['tags']:dynamic, ['timestamp']:datetime)

相应的表映射将如下所示:

.create-or-alter table ['table-name'] ingestion json mapping 'table-name_mapping' '[{"column":"fields", "Properties":{"Path":"$[\'fields\']"}},{"column":"name", "Properties":{"Path":"$[\'name\']"}},{"column":"tags", "Properties":{"Path":"$[\'tags\']"}},{"column":"timestamp", "Properties":{"Path":"$[\'timestamp\']"}}]'

此插件将使用上述命令自动创建表和相应的表映射。

摄取类型

如果使用 managed 操作,则必须在 Eventhouse 上启用 流式摄取

请参阅以下查询以检查流是否已启用:

.show database <DB-Name> policy streamingingestion

要了解有关配置、支持的身份验证方法和查询已摄取数据的更多信息,请查看 文档

Eventstream

Eventstreams 允许您将实时事件引入 Fabric,对其进行转换,然后将其路由到各种目的地,而无需编写任何代码(无代码)。有关更多信息,请访问 Eventstream 文档

要与 eventstream 通信,您需要为命名空间或事件中心指定连接字符串。以下属性可以使用键值对添加到标准的 Eventstream 连接字符串中。

属性名别名描述
分区键PartitionKey用于事件分区键的指标标记或字段名称(如果存在)。如果标记和字段都存在,则标记优先,否则使用值 <default>
最大消息大小MaxMessageSize最大批次消息大小(以字节为单位)。允许的大小取决于事件中心层,有关详细信息,请参阅 层信息。如果未设置,则使用 Eventstream 定义的默认大小(目前为 1,000,000 字节)。

此页面是否有帮助?

感谢您的反馈!


InfluxDB 3.8 新特性

InfluxDB 3.8 和 InfluxDB 3 Explorer 1.6 的主要增强功能。

查看博客文章

InfluxDB 3.8 现已适用于 Core 和 Enterprise 版本,同时发布了 InfluxDB 3 Explorer UI 的 1.6 版本。本次发布着重于操作成熟度,以及如何更轻松地部署、管理和可靠地运行 InfluxDB。

更多信息,请查看

InfluxDB Docker 的 latest 标签将指向 InfluxDB 3 Core

在 **2026 年 2 月 3 日**,InfluxDB Docker 镜像的 latest 标签将指向 InfluxDB 3 Core。为避免意外升级,请在您的 Docker 部署中使用特定的版本标签。

如果使用 Docker 来安装和运行 InfluxDB,latest 标签将指向 InfluxDB 3 Core。为避免意外升级,请在您的 Docker 部署中使用特定的版本标签。例如,如果使用 Docker 运行 InfluxDB v2,请将 latest 版本标签替换为 Docker pull 命令中的特定版本标签 — 例如

docker pull influxdb:2