Функции для работы с событиями и логами
Функции поиска событий в хранилище
FilterCollectorEvents
Назначение: Фильтрация событий, записанных через потоки данных
Описание: Функция выполняет запрос к API, аналогичный выполняемому на экране «События и логи». Обращается в хранилище событий и логов Clickhouse и получает записанные в нем события в соответствии с настроенным фильтром.
Inputs
| Название | Тип | Описание |
|---|---|---|
| In, BearerToken | Общие параметры для функций | |
| Query | String | Текст запроса (формат Lucene) |
| FilteredCount | Integer | Кол-во запрашиваемых событий (по умолчанию выводит 500 событий) |
| Timestamp | Struct:DateRange | Период запрашиваемых событий |
| StreamIds | Integer64 (Array) | Идентификаторы потоков данных |
| TimestampSortDirection | Enum:SortDirectionTypes | Сортировка по возрастанию/убыванию |
| Interval | Integer | Интервал (в сек.), по которому будут разбиты агрегированные данные по кол-ву событий за период времени. При значении 0 агрегация происходить не будет |
Outputs
| Название | Тип | Описание |
|---|---|---|
| Ok, Failed, Response | Общие параметры для функций | |
| Result | Struct:StreamDataFilterResult | Результаты запроса |
Struct - StreamDataFilterResult
Описание структуры Struct:StreamDataFilterResult:
| Пин | Тип | Описание |
|---|---|---|
| Aggregations | Struct:StreamDataAggregateMode | Список агрегированных данных по кол-ву событий за период времени (результат работы пина Interval) |
| Documents | Struct:CollectorLogEvent | Список событий за период времени |
Struct - StreamDataAggregateMode
Описание структуры Struct:StreamDataAggregateMode:
| Пин | Тип | Описание |
|---|---|---|
| Timestamp | Struct:DataTimeOffset | Список агрегированных данных по кол-ву событий за период времени (результат работы пина Interval) |
| Count | Integer | Список событий за период времени |