Logstash

Статья создана

Обновлена 13 января 2026 г.

Примечание

Вы можете создать триггер, который будет запускать функцию Cloud Functions или контейнер Serverless Containers при отправке данных в поток. Подробнее о триггере для Data Streams.

Скачайте и установите Logstash.
Установите плагин для поддержки протокола AWS Kinesis Data Streams. По этому протоколу будет осуществляться поставка данных.
```
sudo /usr/share/logstash/bin/logstash-plugin install logstash-output-kinesis
```
Примечание

Плагин использует библиотеку Amazon Kinesis Producer Library. Для ее работы необходим Java Development Kit (JDK). Скачайте и установите его для вашей платформы. При запуске убедитесь, что используется версия JDK 1.8.235 или выше.
В консоли управления выберите каталог, в котором находится поток данных.
Перейдите в сервис Data Streams.
Выберите поток данных.
Нажмите Подключиться и перейдите на вкладку Logstash.

Скопируйте пример файла конфигурации и вставьте его в файл /usr/share/logstash/bin/mypipeline.conf.

Пример файла конфигурации:

input {
  http {
    port => 8888
  }
}
output {
  stdout { codec => rubydebug}
  kinesis {
    stream_name => "/kz1/aoegtvhtp8ob********/cc8004q4lbo6********/test"
    region => "ru-central-1"
    verify_certificate => false
    codec => json_lines
    randomized_partition_key => true
    access_key => "<идентификатор_ключа_доступа>"
    secret_key => "<секретный_ключ>"
    metrics_level => "none"
    endpoint => "https://yds.serverless.yandexcloud.net"
  }
}

Где:

<идентификатор_ключа_доступа> — идентификатор статического ключа доступа.
<секретный_ключ> — секретная часть статического ключа доступа.

Запустите поставку данных:

sudo /usr/share/logstash/bin/logstash -f mypipeline.conf

Отправьте тестовые данные в Logstash:

curl \
  --request PUT 'http://127.0.0.1:8888/kinesis' \
  --header "content-type: application/json" \
  --data '{"user_id":"user1", "score": 100}'

Если настройка выполнена успешно, в консоли работы Logstash появится сообщение о получении данных и отправке их в Data Streams по протоколу AWS Kinesis Data Streams:

{
  "@version" => "1",
  "headers" => {
    "request_path" => "/kinesis",
    "http_version" => "HTTP/1.1",
    "content_type" => "application/json",
    "http_host" => "127.0.0.1:8888",
    "http_accept" => "*/*",
    "request_method" => "PUT",
    "content_length" => "18",
    "http_user_agent" => "curl/7.68.0"
  },
  "host" => "127.0.0.1",
  "json" => "message"
}
Stage 1 Triggers: { stream: '/kz1/aoeu1kuk2dht********/cc8029jgtuab********/logstash_stream', manual: 0, count: 0, size: 0, matches: 0, timed: 0, UserRecords: 0, KinesisRecords: 0 }
Stage 2 Triggers: { stream: '/kz1/aoeu1kuk2dht********/cc8029jgtuab********/logstash_stream', manual: 0, count: 0, size: 0, matches: 0, timed: 1, KinesisRecords: 1, PutRecords: 1 }
(test) Average Processing Time: 723 ms

Logstash

Была ли статья полезна?