loki.source.azure_event_hubs

loki.source.azure_event_hubs 通过使用事件中心上的 Apache Kafka 终端来接收 Azure 事件中心的消息。有关更多信息，请参阅 Azure 事件中心文档。

要了解如何将 Azure 日志流式传输到 Azure 事件中心，请参阅 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`	`list(string)`	要消费的事件中心。		是
`group_id`	`字符串`	Kafka 消费者组 ID。	`"loki.source.azure_event_hubs"`	否
`assignor`	`字符串`	要使用的消费者组重新平衡策略。	`"range"`	否
`use_incoming_timestamp`	`bool`	是否使用从 Azure 事件中心接收的时间戳。	`false`	否
`labels`	`map(string)`	要关联到每个接收事件的标签。	`{}`	否
`forward_to`	`list(LogsReceiver)`	要发送日志条目的接收者列表。		是
`relabel_rules`	`RelabelRules`	要应用在日志条目上的重命名规则。	`{}`	否
`disallow_custom_messages`	`bool`	是否忽略不匹配 Azure 资源日志模式的消息。	`false`	否

必须将 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云上身份验证的事件中心连接字符串。	否
`作用域`	`list(string)`	访问令牌作用域。默认为不带端口的`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 通过环境变量或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"
	}
}