一旦您为 GCP Logs Viewer 提供了所需的过滤选项,作为最简单的查询,基于您的输入寻找 dataflow_step resource type:
resource.type="dataflow_step"
resource.labels.region="europe-west2"
您可能会观察到从 Cloud Dataflow REST API 检索到的查询结果,其中包含格式为 JSON 输出的日志条目,用于所有驻留在您的 GCP 项目中的 europe-west2Regional endpoint 中的数据流作业:
{
"insertId": "insertId",
"jsonPayload": {
....
"message": "Message content",
....
},
"resource": {
"type": "dataflow_step",
"labels": {
"job_id": "job_id",
"region": "europe-west2",
"job_name": "job_name",
"project_id": "project_id",
"step_id": "step_id"
}
},
"timestamp": "timestamp",
"severity": "severity_level",
"labels": {
"compute.googleapis.com/resource_id": "resource_id",
"dataflow.googleapis.com/job_id": "job_id",
"compute.googleapis.com/resource_type": "resource_type",
"compute.googleapis.com/resource_name": "resource_name",
"dataflow.googleapis.com/region": "europe-west2",
"dataflow.googleapis.com/job_name": "job_name"
},
"logName": "logName",
"receiveTimestamp": "receiveTimestamp"
根据GCP日志服务documentation,每个监控资源类型都从嵌套服务API中派生出特定的标签,dataflow.googleapis.com对应Dataflow服务。
因此,如果您运行 Dataflow Job 定义作业元数据 region 的位置,GCP 日志记录服务将在整个 dataflow.googleapis.com REST 方法中从作业描述中获取此区域端点。