Метод 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 Этот токен позволяет продолжить работу с потоком логов, начиная с этой записи. Чтобы продолжить работу с потоком, укажите значение Это значение взаимозаменяемо с nextPageToken из метода ListLogs. |