› › ›

Azure 事件中心输入

用户可以使用 azure-eventhub 输入来读取 Azure 事件中心中的消息。azure-eventhub 输入的实现基于事件处理器主机 (EPH 旨在跨多个进程和机器运行，同时负载均衡消息使用者，更多信息请参见 https://github.com/Azure/azure-event-hubs-go#event-processor-host，https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-event-processor-host)。诸如分区租赁和事件流中的检查点之类的状态通过 Azure 存储容器在接收器之间共享。因此，使用此输入的先决条件是用户必须创建或使用现有的存储帐户。

示例配置

filebeat.inputs:
- type: azure-eventhub
  eventhub: "insights-operational-logs"
  consumer_group: "test"
  connection_string: "Endpoint=sb://....."
  storage_account: "azureeph"
  storage_account_key: "....."
  storage_account_container: ""
  resource_manager_endpoint: ""

配置选项

编辑

azure-eventhub 输入支持以下配置

`eventhub`

编辑

用户想要从中读取的事件中心的名称，此字段必填。

`consumer_group`

编辑

可选，我们建议为 Azure 输入使用专用使用者组。在不相关的使用者之间重用使用者组可能会导致意外行为，并可能丢失事件。

`connection_string`

编辑

与事件中心通信所需的连接字符串，步骤请参见 https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string。

需要一个 Blob 存储帐户来存储/检索/更新事件中心消息的偏移量或状态。这意味着在停止 Filebeat 后，它可以从停止处理消息的位置重新启动。

`storage_account`

编辑

存储帐户的名称。必填。

`storage_account_key`

编辑

存储帐户密钥，此密钥将用于授权访问存储帐户中的数据，此选项必填。

`storage_account_container`

编辑

可选，您要存储偏移量信息的存储帐户容器的名称。

`resource_manager_endpoint`

编辑

可选，默认情况下我们使用 Azure 公共环境，要覆盖此设置，用户可以提供特定的资源管理器端点以使用不同的 Azure 环境。例如：https://management.chinacloudapi.cn/ 用于 Azure 中国区云 https://management.microsoftazure.de/ 用于 Azure 德国区云 https://management.azure.com/ 用于 Azure 公共云 https://management.usgovcloudapi.net/ 用于 Azure 美国政府云用户也可以在混合云模型中使用此选项，在这种模型中，用户可以定义自己的端点。

指标

编辑

此输入在 HTTP 监控端点下公开指标。这些指标在 /inputs 路径下公开。它们可用于观察输入的活动。

指标	描述
`received_messages_total`	从事件中心接收到的消息数。
`received_bytes_total`	从事件中心接收到的字节数。
`sanitized_messages_total`	成功清理的消息数。
`processed_messages_total`	成功处理的消息数。
`received_events_total`	解码消息时接收到的事件数。
`sent_events_total`	成功发送的事件数。
`processing_time`	以纳秒为单位的经过处理时间的直方图。
`decode_errors_total`	解码消息时发生的错误数。

« AWS S3 输入 Azure Blob 存储输入 »