Перенос временных рядов Аналитика 1-го поколения в Обозреватель данных Azure

Примечание.

Служба временных рядов Аналитика будет прекращена 7 июля 2024 года. Рассмотрите возможность переноса существующих сред в альтернативные решения как можно скорее. Дополнительные сведения об устаревании и миграции см. в нашей документации.

Обзор

Рекомендуется настроить кластер Azure Data Обозреватель с новой группой потребителей из Концентратора событий или Центр Интернета вещей и ожидать передачи и заполнения Обозреватель данных Azure с теми же данными, что и среда временных рядов Аналитика. Если данные телеметрии необходимы для экспорта из среды временных рядов Аналитика, рекомендуется использовать API запросов временных рядов Аналитика для скачивания событий в пакетах и сериализации в обязательном формате. Для ссылочных данных можно использовать API временных рядов Аналитика Обозреватель или эталонных данных для скачивания эталонного набора данных и передачи их в Обозреватель данных Azure в виде другой таблицы. Затем материализованные представления в Обозреватель данных Azure можно использовать для объединения ссылочных данных с данными телеметрии. Используйте материализованное представление с функцией агрегирования arg_max(), которая получит последнюю запись для каждой сущности, как показано в следующем примере. Дополнительные сведения о материализованных представлениях см. в следующей документации: варианты использования материализованных представлений.

.create materialized-view MVName on table T
{
    T
    | summarize arg_max(Column1,*) by Column2
}

Перевод запросов временных рядов Аналитика в KQL

Для запросов рекомендуется использовать KQL в Обозреватель данных Azure.

События

{
  "searchSpan": {
    "from": "2021-11-29T22:09:32.551Z",
    "to": "2021-12-06T22:09:32.551Z"
  },
  "predicate": {
    "predicateString": "([device_id] = 'device_0') AND ([has_error] != null OR [error_code] != null)"
  },
  "top": {
    "sort": [
      {
        "input": {
          "builtInProperty": "$ts"
        },
        "order": "Desc"
      }
    ],
    "count": 100
  }
}

	events
| where _timestamp >= datetime("2021-11-29T22:09:32.551Z") and _timestamp < datetime("2021-12-06T22:09:32.551Z") and deviceid == "device_0" and (not(isnull(haserror)) or not(isempty(errorcode)))
| top 100 by _timestamp desc

Статистические выражения

{
    "searchSpan": {
      "from": "2021-12-04T22:30:00Z",
      "to": "2021-12-06T22:30:00Z"
    },
    "predicate": {
      "eq": {
        "left": {
          "property": "DeviceId",
          "type": "string"
        },
        "right": "device_0"
      }
    },
    "aggregates": [
      {
        "dimension": {
          "uniqueValues": {
            "input": {
              "property": "DeviceId",
              "type": "String"
            },
            "take": 1
          }
        },
        "aggregate": {
          "dimension": {
            "dateHistogram": {
              "input": {
                "builtInProperty": "$ts"
              },
              "breaks": {
                "size": "2d"
              }
            }
          },
          "measures": [
            {
              "count": {}
            },
            {
              "sum": {
                "input": {
                  "property": "DataValue",
                  "type": "Double"
                }
              }
            },
            {
              "min": {
                "input": {
                  "property": "DataValue",
                  "type": "Double"
                }
              }
            },
            {
              "max": {
                "input": {
                  "property": "DataValue",
                  "type": "Double"
                }
              }
            }
          ]
        }
      }
    ]
  }

	let _q = events | where _timestamp >= datetime("2021-12-04T22:30:00Z") and _timestamp < datetime("2021-12-06T22:30:00Z") and deviceid == "device_0";
let _dimValues0 = _q | project deviceId | sample-distinct 1 of deviceId;
_q
| where deviceid in (_dimValues0) or isnull(deviceid)
| summarize
    _meas0 = count(),
    _meas1 = iff(isnotnull(any(datavalue)), sum(datavalue), any(datavalue)),
    _meas2 = min(datavalue),
    _meas3 = max(datavalue),
    by _dim0 = deviceid, _dim1 = bin(_timestamp, 2d)
| project
    _dim0,
    _dim1,
    _meas0,
    _meas1,
    _meas2,
    _meas3,
| sort by _dim0 nulls last, _dim1 nulls last