ModifyLogstashPipeline#

Description#

Запрос на изменение конвейера данных Logstash в сервисе ELK.

Request Parameters#

  • configuration — Конфигурация конвейера данных.

    • Тип: String

    • Необходимо: Да

  • pipelineId — Идентификатор конвейера данных.

    • Тип: String

    • Необходимо: Да

  • serviceId — Идентификатор сервиса ELK.

    • Тип: String

    • Необходимо: Да

Response Elements#

  • logstashPipeline — Изменённый конвейер данных.

Examples#

Для управления сервисами PaaS в К2 Облаке с помощью API необходима кастомизированная версия библиотеки boto3:

import boto3

session = boto3.Session(
    aws_access_key_id="<AWS_ACCESS_KEY_ID>",
    aws_secret_access_key="<AWS_SECRET_ACCESS_KEY>",
    region_name="",
)

paas_client = session.client(
    'paas',
    endpoint_url='https://paas.k2.cloud/',
)

configuration = """input {
    http {
        port => 5678
        tags => events
    }
    http {
        port => 5555
        tags => api
    }
}
"""

pipeline = paas_client.modify_logstash_pipeline(
    serviceId='fm-cluster-C27426C0',
    pipelineId="logstash-pipeline-7C507C2C",
    configuration=configuration,
)

Или утилита c2-paas из пакета K2 Cloud API Client:

c2-paas ModifyLogstashPipeline serviceId fm-cluster-C27426C0 pipelineId logstash-pipeline-7C507C2C configuration 'input {}'