public String genContent()

in src/main/java/com/aliyun/dts/subscribe/clients/metrics/LogMetricsReporter.java [121:154]

32 lines of code
8 McCabe index (conditional complexity)


    public String genContent(Collection<MetricValue> metricValues) {
        try {
            if (metricValues == null) {
                return null;
            }
            JSONObject jsonObject = new JSONObject();
            for (MetricValue metricValue : metricValues) {
                BigDecimal metricMeasurableValue = null;
                try {
                    metricMeasurableValue = new BigDecimal(String.valueOf(metricValue.value));
                } catch (Exception var8) {
                    // handle hot key info
                    if (StringUtils.equalsIgnoreCase(metricValue.name, "maxQueuedKeyInfo")) {
                        jsonObject.put("maxQueuedKeyInfo", String.valueOf(metricValue.value));
                    }
                    continue;
                }
                String alias = STATIC_KEY_MAPPER.get(metricValue.name);
                if (metricMeasurableValue.scale() > 2) {
                    metricMeasurableValue = metricMeasurableValue.setScale(2, RoundingMode.HALF_UP);
                }
                jsonObject.put(metricValue.name, metricMeasurableValue);
                if (null != alias) {
                    jsonObject.put(alias, metricMeasurableValue);
                }
            }

            jsonObject.put("__dt", (new Date()).getTime());
            return jsonObject.toJSONString();
        } catch (Exception var9) {
            LOG.warn("LogMetricsReporter: format metric failed, cause " + var9.getMessage());
        }
        return null;
    }