文档 Grafana Alloy 参考 组件 loki loki.source.gcplog

Loki GCP 日志源

loki.source.gcplog 通过利用 Pub/Sub 订阅 从云资源（例如 GCS 存储桶、负载均衡器或在 GCP 上运行的 Kubernetes 集群）检索日志。

该组件使用“推送”或“拉取”策略检索日志条目，并将它们转发到 forward_to 中接收器的列表。

可以通过为多个 loki.source.gcplog 组件提供不同的标签来指定它们。

用法

alloy 复制

loki.source.gcplog "LABEL" {
  pull {
    project_id   = "PROJECT_ID"
    subscription = "SUB_ID"
  }

  forward_to = RECEIVER_LIST
}

参数

loki.source.gcplog 支持以下参数

块

在 loki.source.gcplog 的定义中支持以下块

pull 和 push 内部块是互斥的；组件在其定义中必须包含这两个块中的一个。http 和 grpc 块仅在配置 push 块时使用。

pull 块

pull 块定义要从中读取日志条目的 GCP 项目 ID 和订阅。

以下参数可用于配置 pull 块。任何省略的字段都采用其默认值。

为了使用 pull 策略，必须已配置 GCP 项目以将其云资源日志转发到 Pub/Sub 主题，以便 loki.source.gcplog 使用。

通常，主机系统还需要配置其 GCP 凭据。一种方法是将 GOOGLE_APPLICATION_CREDENTIALS 环境变量指向凭据配置 JSON 文件或服务帐户密钥的位置。

push 块

push 块定义接收来自 GCP 的 Pub/Sub 服务器的推送请求的服务器的配置。

以下参数可用于配置 push 块。任何省略的字段都采用其默认值。

服务器侦听来自 GCP 的推送订阅在 HOST:PORT/gcp/api/v1/push 上的 POST 请求。

默认情况下，对于这两种策略，组件都将日志条目时间戳分配为处理它的时间，除非 use_incoming_timestamp 设置为 true。

labels 映射应用于通过组件的每个条目。

HTTP

http 块配置 HTTP 服务器。

您可以使用以下参数配置 http 块。任何省略的字段都采用其默认值。

grpc

grpc 块配置 gRPC 服务器。

您可以使用以下参数配置 grpc 块。任何省略的字段都采用其默认值。

导出字段

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

组件健康状况

仅当 loki.source.gcplog 给定无效配置时，才会报告其不健康。

调试信息

loki.source.gcplog 针对每个 gcplog 侦听器公开一些调试信息

• 配置的策略。
• 它们的标签集。
• 在使用 push 策略时，侦听地址。

调试指标

在使用 pull 策略时，组件会公开以下调试指标

• loki_source_gcplog_pull_entries_total（计数器）：gcplog 目标接收到的条目数。
• loki_source_gcplog_pull_parsing_errors_total（计数器）：接收 gcplog 消息时解析错误的总数。
• loki_source_gcplog_pull_last_success_scrape（gauge）：目标上次成功轮询的时间戳。

在使用 push 策略时，组件会公开以下调试指标

• loki_source_gcplog_push_entries_total（计数器）：gcplog 目标接收到的条目数。
• loki_source_gcplog_push_entries_total（计数器）：接收 gcplog 消息时解析错误的总数。

示例

此示例侦听 0.0.0.0:8080 上的 GCP Pub/Sub PushRequests 并将它们转发到 loki.write 组件。

alloy 复制

loki.source.gcplog "local" {
  push {}

  forward_to = [loki.write.local.receiver]
}

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

另一方面，如果我们需要服务器侦听 0.0.0.0:4040，并将它们转发到 loki.write 组件。

alloy 复制

loki.source.gcplog "local" {
  push {
    http {
        listen_port = 4040
    }
  }

  forward_to = [loki.write.local.receiver]
}

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

兼容组件

loki.source.gcplog 可以接受来自以下组件的参数

• 导出 Loki LogsReceiver 的组件