Подключиться
Yandex Managed Service for Apache Kafka®

Метод streamLogs

То же самое, что listLogs, с той разницей, что со стороны сервера передается поток логов. Допускается использовать семантику tail -f при работе с
потоком логов.

HTTP-запрос

GET https://mdb.api.cloud.yandex.net/managed-kafka/v1/clusters/{clusterId}:stream_logs

Path-параметры

Параметр Описание
clusterId Обязательное поле. Идентификатор кластера Apache Kafka®. Чтобы получить идентификатор кластера Apache Kafka®, выполните запрос list. Максимальная длина строки в символах — 50.

Query-параметры

Параметр Описание
columnFilter Столбцы, которые нужно запросить из лога. Если столбцы не указаны, записи логов возвращаются целиком.
fromTime Временная метка, начиная с которой следует запросить логи. Строка в формате RFC3339.
toTime Временная метка, до которой следует запросить логи. Если значение этого поля не задано, то будут отправлены все существующие записи в логе, а затем и новые по мере их появления. В сущности, это эквивалентно семантике tail -f. Строка в формате RFC3339.
recordToken Токен записи. Задайте значение recordToken равным значению nextRecordToken, возвращенному предыдущим запросом streamLogs чтобы продолжить стриминг со следующей записи в логе. Максимальная длина строки в символах — 100.
filter Выражение, позволяющее отфильтровать информацию о ресурсах в ответе, оставив только нужную. В этом выражении должны быть указаны: 1. Имя поля, по которому нужно выполнить фильтрацию. В настоящее время фильтрацию можно использовать только по полю hostname. 2. Условный оператор. Поддерживаются операторы = и != для одиночных значений, IN и NOT IN для списков значений. 3. Значение. Должно содержать от 3 до 63 символов и соответствовать регулярному выражению ^[a-z][-a-z0-9]{1,61}[a-z0-9]$. Пример фильтра: hostname='node1.db.cloud.yandex.net' Максимальная длина строки в символах — 1000.

Ответ

HTTP Code: 200 - OK

{
  "record": {
    "timestamp": "string",
    "message": "object"
  },
  "nextRecordToken": "string"
}
Поле Описание
record object

Одна из запрошенных записей в логе.

Записи в журнале.
record.
timestamp		 string (date-time)

Временная метка для записи в логе.

Строка в формате RFC3339.
record.
message		 object

Содержимое записи в логе.
nextRecordToken string

Этот токен позволяет продолжить работу с потоком логов, начиная с этой записи.

Чтобы продолжить работу с потоком, укажите значение nextRecordToken в качестве значения параметра recordToken в следующем запросе StreamLogs.

Это значение взаимозаменяемо с nextPageToken из метода ListLogs.
В этой статье: