`loki.source.azure_event_hubs`

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

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

Apache Kafka 端点在基本定价计划中不可用。有关更多信息，请参阅 Event Hubs 定价页面。

您可以通过为 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 一起使用

名称	类型	描述	默认值	必需
`event_hubs`	`list(string)`	要消费的事件中心。		yes
`forward_to`	`list(LogsReceiver)`	要将日志条目发送到的接收器列表。		yes
`fully_qualified_namespace`	`string`	事件中心命名空间。		yes
`assignor`	`string`	要使用的消费者组重新平衡策略。	`"range"`	no
`disallow_custom_messages`	`bool`	是否忽略与 Azure 资源日志架构不匹配的消息。	`false`	no
`group_id`	`string`	Kafka 消费者组 ID。	`"loki.source.azure_event_hubs"`	no
`labels`	`map(string)`	要与每个收到的事件关联的标签。	`{}`	no
`relabel_rules`	`RelabelRules`	要应用于日志条目的重新标记规则。	`{}`	no
`use_incoming_timestamp`	`bool`	是否使用从 Azure 事件中心接收的时间戳。	`false`	no

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 一起使用

名称	描述	必需
`authentication`	与 Azure 事件中心的身份验证配置。	yes

`authentication`

必需

authentication 块定义了与 Azure 事件中心通信时的身份验证方法。

名称	类型	描述	必需
`mechanism`	`string`	身份验证机制。	yes
`connection_string`	`secret`	用于 Azure 云上身份验证的事件中心连接字符串。	no
`scopes`	`list(string)`	访问令牌作用域。默认为不带端口的 `fully_qualified_namespace`。	no

mechanism 支持值 "connection_string" 和 "oauth"。如果使用 "connection_string"，则必须设置 connection_string 属性。如果使用 "oauth"，则必须通过环境变量或 Azure CLI 配置受支持的凭据类型之一。

导出的字段

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

组件健康状况

仅当 loki.source.azure_event_hubs 配置无效时，才会被报告为不健康。

调试信息

loki.source.azure_event_hubs 不公开额外的调试信息。

示例

此示例从 Azure 事件中心消费消息，并使用 OAuth 2.0 进行身份验证。

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"
    }
}