Metrics overview

This page describes the metrics that help you monitor the health andperformance of your Cloud Data Fusion instances and pipelines. UseCloud Monitoring to monitor these metrics. The metrics provide insightsinto pipeline runs, instance details, API requests, and authorization checks.

The metrics are categorized as eitherpipeline metrics orinstance metrics:

  • Pipeline metrics provide data about individual pipeline runs, such asrun status, duration, latency, and data throughput.
  • Instance metrics provide aggregated information about the pipelineswithin an instance, including service availability, the number of deployedpipelines, and API request counts.

Filter and aggregate Cloud Data Fusion pipeline and instance metrics inMonitoring usingmetric andmonitored-resource labels.When youcustomize your metrics views,you can use one or both of these label types.

Cloud Data Fusion Pipeline monitored-resource labels

Filter and aggregate the metrics with the followingCloud Data FusionPipeline monitored-resource labels:

Label nameDescription
resource_containerThe ID of the customer project.
org_idThe ID of the organization that the customer project belongs to.
locationThe zone or region where the instance is hosted.
editionThe edition of the Cloud Data Fusion instance.
is_private_ip_enabledWhether the instance uses an internal IP address.
versionThe Cloud Data Fusion data plane version of the instance.
instance_idThe Cloud Data Fusion instance ID.
namespaceThe namespace of the pipeline.
pipeline_idThe pipeline ID.
run_idThe run ID for the pipeline.

Pipeline metric labels

Filter and aggregate the metrics with the following Cloud Data Fusionmetric labels in Monitoring:

NameMetricDescriptionMetric labels
Pipeline run statusdatafusion.googleapis.com/pipeline/v2/runs_completed_countThe cumulative count of pipelines that have completed a run.
  • complete_state
  • previous_state
  • program
  • provisioner
  • cluster_state
  • compute_profile_id
  • enable_rbac
  • private_service_connect_enabled
Pipeline run timedatafusion.googleapis.com/pipeline/v2/pipeline_durationTime taken to complete the pipeline run.
  • complete_state
  • program
  • provisioner
  • cluster_state
  • compute_profile_id
  • enable_rbac
  • private_service_connect_enabled
Pipeline start latencydatafusion.googleapis.com/pipeline/v2/pipeline_start_latencyThe time taken for the pipeline to reachRunning state.
  • program
  • provisioner
  • cluster_state
  • compute_profile_id
  • complete_state
  • enable_rbac
  • private_service_connect_enabled
Provisioning latencydatafusion.googleapis.com/pipeline/v2/dataproc/provisioning_latencyThe Dataproc cluster provisioning latency.
  • provisioner
  • enable_rbac
  • private_service_connect_enabled
Dataproc API requestsdatafusion.googleapis.com/pipeline/v2/dataproc/api_request_countThe cumulative count of Dataproc API requests.
  • provisioner
  • method
  • response_code
  • region
  • launch_mode
  • image_version
  • enable_rbac
  • private_service_connect_enabled
Pipeline preview run timedatafusion.googleapis.com/pipeline/v2/preview_durationTime taken to complete preview.
  • complete_state
  • enable_rbac
  • private_service_connect_enabled
Pipeline bytes writtendatafusion.googleapis.com/pipeline/v2/write_bytes_countThe cumulative count of bytes written by a pipeline.
  • enable_rbac
  • private_service_connect_enabled
Pipeline bytes readdatafusion.googleapis.com/pipeline/v2/read_bytes_countThe cumulative count of bytes read by a pipeline.
  • enable_rbac
  • private_service_connect_enabled
Pipeline bytes shuffleddatafusion.googleapis.com/pipeline/v2/shuffle_bytes_countThe cumulative count of bytes shuffled in a pipeline.
  • enable_rbac
  • private_service_connect_enabled
Plugin records processed indatafusion.googleapis.com/pipeline/v2/plugin/incoming_records_countCumulative count of records entering a plugin.
  • enable_rbac
  • private_service_connect_enabled
  • stage_name
Plugin records processed outdatafusion.googleapis.com/pipeline/v2/plugin/outgoing_records_countThe cumulative count of records exiting a plugin.
  • enable_rbac
  • private_service_connect_enabled
  • stage_name

Cloud Data Fusion Instance monitored-resource labels

Filter and aggregate the metrics with the followingCloud Data FusionInstance monitored-resource labels:

Label nameDescription
resource_containerThe ID of the customer project.
org_idThe ID of the organization that the customer project belongs to.
locationThe zone or region where the instance is hosted.
editionThe edition of the instance.
is_private_ip_enabledWhether the instance uses an internal IP address.
versionThe Cloud Data Fusion data plane version of the instance.
instance_idThe Cloud Data Fusion instance ID.
namespaceThe namespace name.

Instance metric labels

Filter and aggregate the metrics with the following Cloud Data Fusionmetric labels in Monitoring:

NameMetricDescriptionMetric labels
Service statusdatafusion.googleapis.com/instance/v2/service_availableThe availability of Cloud Data Fusion services.
  • service
  • enable_rbac
  • private_service_connect_enabled
Deployed pipeline countdatafusion.googleapis.com/instance/v2/pipelinesThe number of deployed pipelines.
  • enable_rbac
  • private_service_connect_enabled
  • maintenance_window_enabled
Concurrent pipelines running countdatafusion.googleapis.com/instance/v2/concurrent_pipelines_runningThe number of pipelines running concurrently.
  • enable_rbac
  • private_service_connect_enabled
Concurrent pipeline launches countdatafusion.googleapis.com/instance/v2/concurrent_pipelines_launchedThe number of pipelines in eitherProvisioning orStarting state.
  • enable_rbac
  • private_service_connect_enabled
CDAP REST API requests receiveddatafusion.googleapis.com/instance/v2/api_request_countThe cumulative count of REST API requests received by a service in the backend.
  • service
  • handler
  • method
  • enable_rbac
  • private_service_connect_enabled
CDAP REST API responses sentdatafusion.googleapis.com/instance/v2/api_response_countThe cumulative count of REST API responses sent by a service in the backend.
  • service
  • handler
  • method
  • response_code
  • enable_rbac
  • private_service_connect_enabled
Authorization check countdatafusion.googleapis.com/instance/v2/authorization_check_countThe cumulative count of authorization checks made by the access enforcer.
  • enable_rbac
  • type
  • private_service_connect_enabled
Authorization check timedatafusion.googleapis.com/instance/v2/authorization_check_timeThe latency of authorization checks made by the access enforcer.
  • enable_rbac
  • type
  • private_service_connect_enabled
Draft pipeline countdatafusion.googleapis.com/instance/v2/draft_pipelinesThe number of draft pipelines.
  • enable_rbac
  • private_service_connect_enabled
Namespace countdatafusion.googleapis.com/instance/v2/namespacesThe number of namespaces.
  • enable_rbac
  • private_service_connect_enabled

What's next

Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025-12-15 UTC.