Extend the platform,
empower your team.
Get insights into Google Dataflow service metrics collected from the Google Operations API to ensure health of your cloud infrastructure.
ExtensionThis Dynatrace extension leverages data collected from the Google Operations API to constantly monitor health and performance of Google Dataflow services. This extension combines all relevant data into pre-configured dashboards and provides alerting and event tracking.
View and analyze 23 metrics that are specific to Google Dataflow, like Billable shuffle data processed, Current number of vCPUs in use, Current shuffle slots in use, and more.
Build custom dashboards for your cloud infrastructure.
Analyze Google Dataflow logs.
Set custom alerts that trigger remediation workflows.
Google Dataflow metric and log ingestion requires advanced GCP integration.
This extension package contains:
To provide correlation and causation analysis all ingested metrics and logs are analyzed by the Dynatrace Davis AI engine, which consumes DDUs.
Below is a complete list of the feature sets provided in this version. To ensure a good fit for your needs, individual feature sets can be activated and deactivated by your administrator during configuration.
Metric name | Metric key | Description | Unit |
---|---|---|---|
Per-stage backlog in bytes | cloud.gcp.dataflow_googleapis_com.job.backlog_bytes | - | Byte |
Per-stage backlog in elements | cloud.gcp.dataflow_googleapis_com.job.backlog_elements | - | Count |
BigQueryIO.Write Requests | cloud.gcp.dataflow_googleapis_com.job.bigquery.write_count | - | Count |
Billable shuffle data processed | cloud.gcp.dataflow_googleapis_com.job.billable_shuffle_data_processed | - | Byte |
Bundle user processing latencies | cloud.gcp.dataflow_googleapis_com.job.bundle_user_processing_latencies | - | MilliSecond |
Current number of vCPUs in use | cloud.gcp.dataflow_googleapis_com.job.current_num_vcpus | - | Count |
Current shuffle slots in use | cloud.gcp.dataflow_googleapis_com.job.current_shuffle_slots | - | Count |
Data watermark lag | cloud.gcp.dataflow_googleapis_com.job.data_watermark_age | - | Second |
Disk Space Capacity | cloud.gcp.dataflow_googleapis_com.job.disk_space_capacity | - | Byte |
Duplicate message count per stage | cloud.gcp.dataflow_googleapis_com.job.duplicates_filtered_out_count | - | Count |
Elapsed time | cloud.gcp.dataflow_googleapis_com.job.elapsed_time | - | Second |
Element count | cloud.gcp.dataflow_googleapis_com.job.element_count.gauge | - | Count |
Elements Produced | cloud.gcp.dataflow_googleapis_com.job.elements_produced_count | - | Count |
Estimated byte count | cloud.gcp.dataflow_googleapis_com.job.estimated_byte_count.gauge | - | Byte |
Estimated Bytes Produced | cloud.gcp.dataflow_googleapis_com.job.estimated_bytes_produced_count | - | Count |
Failed | cloud.gcp.dataflow_googleapis_com.job.is_failed | - | Count |
Memory Capacity | cloud.gcp.dataflow_googleapis_com.job.memory_capacity | - | Byte |
Per-stage data watermark lag | cloud.gcp.dataflow_googleapis_com.job.per_stage_data_watermark_age | - | Second |
Per-stage system lag | cloud.gcp.dataflow_googleapis_com.job.per_stage_system_lag | - | Second |
The approximate number of parallel processing keys | cloud.gcp.dataflow_googleapis_com.job.processing_parallelism_keys | - | Count |
Pub/Sub Late Messages Count | cloud.gcp.dataflow_googleapis_com.job.pubsub.late_messages_count | - | Count |
Pub/Sub Published Messages Count | cloud.gcp.dataflow_googleapis_com.job.pubsub.published_messages_count | - | Count |
Pub/Sub Pulled Message Ages | cloud.gcp.dataflow_googleapis_com.job.pubsub.pulled_message_ages | - | MilliSecond |
PubsubIO.Read requests from Dataflow jobs | cloud.gcp.dataflow_googleapis_com.job.pubsub.read_count | - | Count |
Pub/Sub Pull Request Latencies | cloud.gcp.dataflow_googleapis_com.job.pubsub.read_latencies | - | MilliSecond |
Percentage of active/terminated Streaming Pull connections | cloud.gcp.dataflow_googleapis_com.job.pubsub.streaming_pull_connection_status | - | Percent |
Pub/Sub Publish Requests | cloud.gcp.dataflow_googleapis_com.job.pubsub.write_count | - | Count |
Pub/Sub Publish Request Latencies | cloud.gcp.dataflow_googleapis_com.job.pubsub.write_latencies | - | MilliSecond |
Status | cloud.gcp.dataflow_googleapis_com.job.status | - | Unspecified |
Storage bytes read | cloud.gcp.dataflow_googleapis_com.job.streaming_engine.persistent_state.read_bytes_count | - | Count |
Storage bytes written | cloud.gcp.dataflow_googleapis_com.job.streaming_engine.persistent_state.write_bytes_count | - | Count |
Storage write latencies | cloud.gcp.dataflow_googleapis_com.job.streaming_engine.persistent_state.write_latencies | - | MilliSecond |
Per stage end to end latencies. | cloud.gcp.dataflow_googleapis_com.job.streaming_engine.stage_end_to_end_latencies | - | MilliSecond |
System lag | cloud.gcp.dataflow_googleapis_com.job.system_lag | - | Second |
Thread Time | cloud.gcp.dataflow_googleapis_com.job.thread_time | - | MilliSecond |
Timers pending count per stage | cloud.gcp.dataflow_googleapis_com.job.timers_pending_count | - | Count |
Timers processed count per stage | cloud.gcp.dataflow_googleapis_com.job.timers_processed_count | - | Count |
Total memory usage time | cloud.gcp.dataflow_googleapis_com.job.total_memory_usage_time | - | GigaByte |
Total PD usage time | cloud.gcp.dataflow_googleapis_com.job.total_pd_usage_time | - | GigaByte |
Total SECU usage | cloud.gcp.dataflow_googleapis_com.job.total_secu_usage | - | Unspecified |
Total shuffle data processed | cloud.gcp.dataflow_googleapis_com.job.total_shuffle_data_processed | - | Byte |
Total streaming data processed | cloud.gcp.dataflow_googleapis_com.job.total_streaming_data_processed | - | Byte |
Total vCPU time | cloud.gcp.dataflow_googleapis_com.job.total_vcpu_time | - | Second |
User Counter | cloud.gcp.dataflow_googleapis_com.job.user_counter | - | Count |
No release notes
No release notes