Интеграция корпоративных данных часто подразумевает сложные требования к очистке и агрегации разнородных данных из нескольких источников, таких как базы данных, журналы и очереди сообщений. Ручное написание файлов конфигурации Logstash может быть сложным из‑за сложного синтаксиса и отладки. Это также может создавать риски безопасности, например, когда пароли к базам данных или другие учётные данные хранятся в открытом виде в файлах конфигурации. CSS Logstash решает эти задачи с помощью визуального центра конфигурации, который позволяет создавать безопасные, эффективные и легко управляемые конвейеры обработки данных. Центр конфигурации позволяет быстро генерировать ETL‑логику, используя пользовательский шаблон и удобные функции, помогающие разработчикам. Встроенная функция маскирования конфиденциальной информации помогает защищать учётные данные пользователей и другие конфиденциальные данные. Вы также можете тонко настраивать параметры конвейера, такие как параллелизм и буферизация, чтобы удовлетворять разнообразные требования к производительности и пропускной способности.
Файл конфигурации Logstash определяет конвейер, состоящий из трёх этапов:
Для получения дополнительной информации о них см. официальную документацию Logstash Plugins.
Параметр | Описание |
|---|---|
Имя | Имя пользовательского файла конфигурации. Он может содержать только буквы, цифры, дефисы (-) и подчёркивания (_), и должен начинаться с буквы. Минимальная длина — 4 символа. Рекомендуется включать в имя файла конфигурации описание назначения данных для упрощения управления. |
Содержимое файла конфигурации | Определите логику ввода, фильтрации и вывода. Чтобы использовать шаблон файла конфигурации, разверните System Templates или Custom Templates, выберите шаблон по его описанию и нажмите Apply в столбце Operation, чтобы скопировать содержимое шаблона.
Размер каждого файла конфигурации не может превышать 100 КБ. |
Скрытое содержимое | Укажите строки, которые нужно скрыть в файле конфигурации, например пароли и ключи доступа. Нажмите Enter после каждой строки. Эти строки будут отображаться как *** в файле конфигурации. Можно настроить не более 20 строк для скрытия, каждая из которых может иметь максимальную длину 512 байт. |
Описание | Добавьте описание файла конфигурации для удобной идентификации. Значение может содержать от 0 до 128 символов. |
Параметр | Категория | Значение по умолчанию | Описание |
|---|---|---|---|
pipeline.workers | Контроль параллелизма | Количество ядер CPU | Количество рабочих потоков, которые параллельно выполняют стадии Filters и Outputs конвейера.
Не превышайте количество ядер CPU на одном узле. В противном случае увеличенные затраты на переключение контекста ухудшат производительность. |
pipeline.batch.size | Пропускная способность | 125 | Максимальное количество событий, которое рабочий поток собирает из входов перед попыткой выполнить его filters и outputs. При обработке большого количества небольших документов увеличение этого значения (например, с 500 до 3000) может значительно повысить пропускную способность. Однако из‑за ограниченной памяти кучи JVM слишком высокое значение может привести к ошибкам out of memory (OOM). |
pipeline.batch.delay | Управление задержкой | 50 | Максимальное время в миллисекундах, которое worker pipeline ожидает новое событие, пока текущая партия ещё не заполнена. Единица: ms Уменьшите значение этого параметра, когда в приоритете производительность в реальном времени. |
queue.type | Надёжность данных | memory | Настраивает внутреннюю очередь для буферизации событий.
|
queue.checkpoint.writes | Чекпоинт | 1024 (recommended) | Максимальное количество записанных событий до принудительного чекпоинта. Этот параметр необходимо установить только когда queue.type установлен в persisted. |
queue.max_bytes | Очередь на диске | 1024 (рекомендовано) | Общая емкость постоянной очереди.
Единица: MB |
Вы можете редактировать существующие файлы конфигурации, установить файл конфигурации в качестве пользовательского шаблона и удалять файлы конфигурации.
Operation | Constraints | Руководство по операциям |
|---|---|---|
Изменение файла конфигурации | Файл конфигурации, для которого запущена задача конвейера, нельзя изменить. | В списке файлов конфигурации найдите строку, содержащую файл конфигурации, который вы хотите отредактировать, и нажмите Edit в столбце Operation. Измените файл в соответствии с новыми требованиями или исправьте ошибки. |
Установка файла конфигурации в качестве шаблона | N/A | В списке файлов конфигурации нажмите Add to Custom Template в столбце Operation. В открывшемся диалоговом окне задайте имя шаблона, описание и содержимое файла конфигурации, затем нажмите OK. После этого его можно будет использовать в качестве шаблона для последующей настройки файлов конфигурации. |
Резервное копирование файлов конфигурации | N/A | Нажмите |
Удаление файла конфигурации |
| В списке файлов конфигурации найдите строку, содержащую файл конфигурации, который вы хотите удалить, и нажмите Delete в столбце Operation. В открывшемся диалоговом окне введите DELETE, затем нажмите OK для подтверждения удаления. |