1

我想使用下面的库执行 MQL（度量查询语言）。

<dependency>
    <groupId>com.google.apis</groupId>
    <artifactId>google-api-services-monitoring</artifactId>
    <version>v3-rev540-1.25.0</version>
</dependency>

这是我的代码片段。这将创建监控客户端并尝试从 GCP 监控中收集数据。

public void queryTimeSeriesData() throws IOException {
        // create monitoring 
        Monitoring m = createAuthorizedMonitoringClient();
        QueryTimeSeriesRequest req  = new QueryTimeSeriesRequest();
        String query = "fetch consumed_api\n" + 
                "| metric 'serviceruntime.googleapis.com/api/request_count'\n" + 
                "| align rate(2m)\n" + 
                "| every 2m\n" + 
                "| group_by [metric.response_code],\n" + 
                "    [value_request_count_max: max(value.request_count)]";
        
        req.setQuery(query);
        HashMap<String, Object> queryTransformationSpec = new HashMap<String, Object>();
        HashMap<String, Object> timingState =  new HashMap<String, Object>();
        HashMap<String, Object> absoluteWindow = new HashMap<String, Object>();
        absoluteWindow.put("startTime", "2020-09-03T12:40:00.000Z");
        absoluteWindow.put("endTime", "2020-09-03T13:41:00.000Z");
        timingState.put("absoluteWindow", absoluteWindow);
        timingState.put("graphPeriod", "60s");
        timingState.put("queryPeriod", "60s");
        queryTransformationSpec.put("timingState", timingState);
        
        
        req.set("queryTransformationSpec", queryTransformationSpec);
        req.set("reportPeriodicStats", false);
        req.set("reportQueryPlan", false);
        
        QueryTimeSeriesResponse res = m.projects().timeSeries().query("projects/MY_PROJECT_NAME", req).execute();
        System.out.println(res);
    }

上面的代码工作正常，但它没有返回给定 startTime 和 endTime 的数据，它总是返回可用的最新数据点。我的代码有问题吗？

4

1 回答 1

3

找到了在给定时间范围内执行 MQL 查询的方法。新的工作代码如下：

public void queryTimeSeriesData() throws IOException {
        // create monitoring 
        Monitoring m = createAuthorizedMonitoringClient();
        QueryTimeSeriesRequest req  = new QueryTimeSeriesRequest();
        String query = "fetch consumed_api\n" + 
                "| metric 'serviceruntime.googleapis.com/api/request_count'\n" + 
                "| align rate(5m)\n" + 
                "| every 5m\n" + 
                "| group_by [metric.response_code],\n" + 
                "    [value_request_count_max: max(value.request_count)]" + 
                "| within   d'2020/09/03-12:40:00', d'2020/09/03-12:50:00'\n";
        
        req.setQuery(query);
        QueryTimeSeriesResponse res = m.projects().timeSeries().query("projects/MY_PROJECT_NAME", req).execute();
        System.out.println(res);
    }

使用within运算符在查询本身中包含查询开始时间和结束时间。根据 MQL 查询的谷歌文档：

within - 指定查询输出的时间范围。

于 2020-09-06T09:52:41.320 回答