feat: add opentelemetry counters for sent and acked messages by agrawal-siddharth · Pull Request #2532 · googleapis/java-bigquerystorage · GitHub

Also add network latency, queue length and error counts.

The metrics (other than error counts) are now reported periodically, every second.

nit, I would group all of them under telemetryMetrics.

Done

I believe this can be derived from network_response_latency, if you put connection_id as the metrics field.

I have added writer_id as an attribute. I still have this metric, however, as it directly provides information about establishing a connection.

It will need connection_id as metrics field, otherwise it doesn't make too much sense?

I have added writer_id as an attribute.

I think we should maintain less metrics. Can we just add a "result" field to append_requests/rows/bytes?

Done. I have removed the following metrics: append_requests, append_request_bytes, append_rows, waiting_queue_length, connection_retry_count, append_requests_error, append_request_bytes_error, append_rows_error.

I now use the "error_code" attribute on each of the following metrics: append_requests_acked, append_request_bytes_acked, append_rows_acked, connection_end_count.

are these millis/micros/nanos?

Renamed this to METRICS_MILLISECONDS_LATENCY_BUCKETS.

Are metrics updates really that costly on the producer side that you don't just update metrics at time of event?

In opencensus, flushing/updates were mostly an exporter concern.

I am testing using an exporter to Google Cloud Monitoring. I encountered "exceeded max frequency" errors with this exporter. To resolve this issue, I have switched to updating the instruments only once every second, which I believe should be sufficient for our needs.

Upon further inspection, I narrowed down the issue I was seeing to the frequency of the exporter. I have restored all metrics to be instrumented in real time.

@GaoleMeng Do these buckets look good to you? Do we need a bucket at 50L? Maybe add a 2000L?

this is too sparse, in backend we are using power of 1.5 bucket, that means it's
1 1.5 1.5^2 1.5^3.... millisecond

We were once using power of 4, but found that was too sparse, so we reduced it to power of 1.5
could we do similar bucketing here?

The power of 1.5 sequence looks like this:

1, 2, 3, 5, 8, 11, 17, 26, 38, 58, 86, 130, 195, 292, 438, 657, 985, 1478, 2217, 3325, 4988, 7482, 11223, 16834, 25251, 37877, 56815, 85223, 127834, 191751, 287627, 431440, 647160, 970740, 1456110

Would it be useful to provide all of these buckets? Alternatively, we could just provide every other bucket, so the list looks like this:

1, 3, 8, 17, 38, 86, 195, 438, 985, 2217, 4988, 11223, 25251, 56815, 127834, 287627, 647160, 1456110

Add some comment to buildOpenTelemetryAttributes, what kind of attributes it is building and does this apply to all metrics?

Added

Discussed with Gaole, we think that maybe the Sent and Ack won't make a significant difference. Let's just record Ack for now for simplicity.

Done

This can be a TODO, I am wondering if it is possible to have a Retry attribute to the metric.

Done

LGTM, please address the bucket length issue.

Do we need to have 1L, 3L and 8L?

I have removed these. I now start at 0 (as the lowest bucket boundary) and end at 647160 which represents about 10 minutes.

Also add network latency, queue length and error counts. The metrics (other than error counts) are now reported periodically, every second.

…pis#2532) Also add network latency, queue length and error counts. The metrics (other than error counts) are now reported periodically, every second.

agrawal-siddharth requested review from a team and alvarowolfx June 18, 2024 02:23

product-auto-label Bot added size: m Pull request size is medium. api: bigquerystorage Issues related to the googleapis/java-bigquerystorage API. labels Jun 18, 2024

agrawal-siddharth requested review from shollyman and yirutang June 18, 2024 02:23

yirutang reviewed Jun 21, 2024

View reviewed changes

yirutang requested a review from GaoleMeng June 21, 2024 00:13

shollyman reviewed Jul 9, 2024

View reviewed changes

agrawal-siddharth force-pushed the openMetrics2 branch 2 times, most recently from 3caa290 to b6b30cf Compare July 19, 2024 15:36

product-auto-label Bot added size: l Pull request size is large. and removed size: m Pull request size is medium. labels Jul 19, 2024

agrawal-siddharth force-pushed the openMetrics2 branch from b6b30cf to 796ae3e Compare July 19, 2024 20:42

product-auto-label Bot added size: m Pull request size is medium. and removed size: l Pull request size is large. labels Jul 19, 2024

agrawal-siddharth force-pushed the openMetrics2 branch 3 times, most recently from 0b87d97 to ad164fb Compare July 22, 2024 16:58

yirutang reviewed Jul 23, 2024

View reviewed changes

agrawal-siddharth force-pushed the openMetrics2 branch from ad164fb to 73c9193 Compare July 24, 2024 00:27

yirutang approved these changes Jul 24, 2024

View reviewed changes

agrawal-siddharth force-pushed the openMetrics2 branch from 73c9193 to 0572a47 Compare July 24, 2024 20:50

yirutang reviewed Jul 24, 2024

View reviewed changes

feat: add opentelemetry counters for sent and acked messages

8ac0ed2

Also add network latency, queue length and error counts. The metrics (other than error counts) are now reported periodically, every second.

agrawal-siddharth force-pushed the openMetrics2 branch from 0572a47 to 8ac0ed2 Compare July 24, 2024 21:21

agrawal-siddharth merged commit 2fc5c55 into googleapis:main Jul 24, 2024

release-please Bot mentioned this pull request Jul 24, 2024

chore(main): release 3.8.0 #2576

Merged

agrawal-siddharth deleted the openMetrics2 branch August 14, 2024 16:34

release-please Bot mentioned this pull request Dec 15, 2025

chore(protobuf-4.x-rc): release 3.20.0-rc1 #3127

Merged

                     };
+                static AttributeKey<String> telemetryKeyErrorCode = AttributeKey.stringKey("error_code");
                 private Attributes telemetryAttributes;
+                private long incomingRequestCountBuffered;

+                              "Reports time taken in milliseconds for a response to arrive once a message has been sent over the network.")
+                          .setExplicitBucketBoundariesAdvice(METRICS_LATENCY_BUCKETS)
+                          .build();
+                  instrumentConnectionEstablishCount =

+                            measurement.record(length, getTelemetryAttributes());
+                          });
+                  writeMeter
+                      .gaugeBuilder("inflight_queue_length")

+                          .build();
+                  instrumentSentRequestRows =
+                      writeMeter
+                          .counterBuilder("append_rows_sent")

+                private LongCounter instrumentErrorRequestCount;
+                private LongCounter instrumentErrorRequestSize;
+                private LongCounter instrumentErrorRequestRows;
+                private static final List<Long> METRICS_LATENCY_BUCKETS =

+                private void periodicallyReportOpenTelemetryMetrics() {
+                  Duration durationSinceLastRefresh = Duration.between(instantLastSentMetrics, Instant.now());
+                  if (durationSinceLastRefresh.compareTo(METRICS_UPDATE_INTERVAL) > 0) {

-                private LongCounter instrumentIncomingRequestSize;
-                private LongCounter instrumentIncomingRequestRows;
+                private static final List<Long> METRICS_MILLISECONDS_LATENCY_BUCKETS =
+                    ImmutableList.of(0L, 50L, 100L, 500L, 1000L, 5000L, 10000L, 20000L, 30000L, 60000L, 120000L);

                   if (!tableName.isEmpty()) {
                     builder.put(telemetryKeyTableId, tableName);
                   }
+                  builder.put(telemetryKeyWriterId, writerId);

+                    ImmutableList.of(0L, 50L, 100L, 500L, 1000L, 5000L, 10000L, 20000L, 30000L, 60000L, 120000L);
+                private static final class OpenTelemetryMetrics {
+                  private LongCounter instrumentSentRequestCount;

                       writeMeter
-                          .counterBuilder("append_requests")
-                          .setDescription("Counts number of incoming requests")
+                          .counterBuilder("append_requests_acked")

feat: add opentelemetry counters for sent and acked messages by agrawal-siddharth · Pull Request #2532 · googleapis/java-bigquerystorage · GitHub

Uh oh!

feat: add opentelemetry counters for sent and acked messages - #2532

feat: add opentelemetry counters for sent and acked messages#2532agrawal-siddharth merged 1 commit intogoogleapis:maingoogleapis/java-bigquerystorage:mainfrom agrawal-siddharth:openMetrics2agrawal-siddharth/java-bigquerystorage:openMetrics2Copy head branch name to clipboard

Conversation

agrawal-siddharth commented Jun 18, 2024

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

yirutang left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

feat: add opentelemetry counters for sent and acked messages#2532
agrawal-siddharth merged 1 commit into
googleapis:mainfrom
agrawal-siddharth:openMetrics2