Sample code to list_time_series from GCP Pub/Sub

list_time_series.py

# export GOOGLE_APPLICATION_CREDENTIALS='credential file in JSON'

import arrow

from google.cloud import monitoring_v3
from google.cloud.monitoring_v3 import enums
from google.cloud.monitoring_v3.types import TimeInterval, Aggregation
from google.api_core import exceptions

client = monitoring_v3.MetricServiceClient()

# your project name
name = client.project_path('soocii-backend')

end_time = arrow.utcnow()
# lookback one minute
start_time = end_time.shift(minutes=-1)
interval = TimeInterval()
interval.start_time.FromDatetime(start_time.naive)
interval.end_time.FromDatetime(end_time.naive)
view = enums.ListTimeSeriesRequest.TimeSeriesView.FULL

# 每五分鐘平均
aggregation = Aggregation(
    per_series_aligner='ALIGN_MEAN',
    alignment_period={'seconds': 5*60}
)

# Iterate over all results
for d in client.list_metric_descriptors(name):
    if 'pubsub' in d.type:
    # if 'pubsub.googleapis.com/subscription/backlog_bytes' in d.type:
        filter_ = 'metric.type="{}" AND resource.labels.subscription_id="thor-staging-mission-accounting-sub"'.format(d.type)
        try:
            values = client.list_time_series(name, filter_, interval, view)
            # values = client.list_time_series(name, filter_, interval, view, aggregation)
            for v in values:
                print('Descriptor: {}'.format(d))
                print('Value: {}'.format(v))
        except exceptions.InvalidArgument as e:
            continue