Microsoft Fabric 输出插件
此插件将指标写入Fabric Eventhouse 和 Fabric 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_type 为 singletable 时才需要。 |
| 创建表 | CreateTables | 如果为 true(默认值),则创建表和相关的映射。否则,将跳过表和映射的创建。这对于以可能的最低权限(表摄取者角色)运行 Telegraf 非常有用。 |
| 指标分组类型 | MetricsGroupingType | 将指标推送到 Eventhouse 时使用的指标分组类型,可以是 tablepermetric 或 singletable。默认值为“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 字节)。 |
此页面是否有帮助?
感谢您的反馈!
支持和反馈
感谢您成为我们社区的一员!我们欢迎并鼓励您对 Telegraf 和本文档提出反馈和 bug 报告。要获取支持,请使用以下资源
具有年度合同或支持合同的客户可以 联系 InfluxData 支持。