loki.source.azure_event_hubs

loki.source.azure_event_hubs 通过利用 Event Hubs 上的 Apache Kafka 端点接收 Azure Event Hubs 消息。有关更多信息，请参阅 Azure Event Hubs 文档。

要了解如何将 Azure 日志流式传输到 Azure Event Hubs 的更多信息，请参阅 Microsoft 的教程，了解如何将 Azure Active Directory 日志流式传输到 Azure 事件中心。

请注意，基本定价计划中不可用 Apache Kafka 端点。有关更多信息，请参阅事件中心定价页面。

可以通过给他们不同的标签来指定多个 loki.source.azure_event_hubs 组件。

使用方法

loki.source.azure_event_hubs "LABEL" {
	fully_qualified_namespace = "HOST:PORT"
	event_hubs                = EVENT_HUB_LIST
	forward_to                = RECEIVER_LIST

	authentication {
		mechanism = "AUTHENTICATION_MECHANISM"
	}
}

参数

loki.source.azure_event_hubs 支持以下参数

名称	类型	描述	默认值	必需
`fully_qualified_namespace`	`字符串`	事件中心命名空间。		是
`event_hubs`	`列表(字符串)`	要消费的事件中心。		是
`group_id`	`字符串`	Kafka 消费者组 ID。	`"loki.source.azure_event_hubs"`	否
`assignor`	`字符串`	要使用的消费者组重新平衡策略。	`"range"`	否
`use_incoming_timestamp`	`布尔值`	是否使用从 Azure Event Hub 收到的时间戳。	`false`	否
`labels`	`映射(字符串)`	要关联到每个接收事件的标签。	`{}`	否
`forward_to`	`列表(LogsReceiver)`	要发送日志条目的接收器列表。		是
`relabel_rules`	`RelabelRules`	要应用到日志条目上的重命名规则。	`{}`	否
`disallow_custom_messages`	`布尔值`	是否忽略不匹配 Azure 资源日志模式的消息。	`false`	否
`relabel_rules`	`RelabelRules`	要应用到日志条目上的重命名规则。	`{}`	否

fully_qualified_namespace 参数必须指向一个指向您事件中心的完整 HOST:PORT，例如 NAMESPACE.servicebus.windows.net:9093。必须将 assignor 参数设置为 "range"、"roundrobin" 或 "sticky" 中的一个。

relabel_rules 字段可以使用来自 loki.relabel 组件的 rules 导出值来应用一个或多个重命名规则，在将日志条目转发到 forward_to 列表中的接收器之前。

块

以下块在 loki.source.azure_event_hubs 的定义内受支持：

层次结构	名称	描述	必需
身份验证	身份验证	使用 Azure Event Hub 的身份验证配置。	是

身份验证块

authentication 块定义了与 Azure Event Hub 通信时的身份验证方法。

名称	类型	描述	必需
`机制`	`字符串`	身份验证机制。	是
`连接字符串`	`字符串`	Azure 云上身份验证的 Event Hubs ConnectionString。	否
`作用域`	`列表(字符串)`	访问令牌作用域。默认为不带端口的 `fully_qualified_namespace`。	否

mechanism 支持的值有 "connection_string" 和 "oauth"。如果使用 "connection_string"，您必须设置 connection_string 属性。如果使用 "oauth"，您必须配置如以下链接中记录的支持的凭证类型之一：[https://github.com/Azure/azure-sdk-for-go/blob/main/sdk/azidentity/README.md#credential-types](https://github.com/Azure/azure-sdk-for-go/blob/main/sdk/azidentity/README.md#credential-types) 通过环境变量或 Azure CLI。

导出字段

loki.source.azure_event_hubs 不导出任何字段。

组件健康状态

如果给定无效配置，则 loki.source.azure_event_hubs 仅报告为不健康。

调试信息

loki.source.azure_event_hubs 不暴露额外的调试信息。

示例

本示例从 Azure Event Hub 消费消息，并使用 OAuth 进行身份验证。

loki.source.azure_event_hubs "example" {
	fully_qualified_namespace = "my-ns.servicebus.windows.net:9093"
	event_hubs                = ["gw-logs"]
	forward_to                = [loki.write.example.receiver]

	authentication {
		mechanism = "oauth"
	}
}

loki.write "example" {
	endpoint {
		url = "loki:3100/api/v1/push"
	}
}