Enterprise интеграция данных часто подразумевает сложные требования к очистке и агрегации разнородных данных из нескольких источников, таких как базы данных, журналы и очереди сообщений. Ручное написание Logstash configuration files может быть сложным из‑за сложного синтаксиса и отладки. Это также может создавать риски безопасности, например, когда пароли баз данных или другие учётные данные хранятся в открытом виде в файлах конфигурации. CSS Logstash решает эти задачи с помощью визуального configuration center, который позволяет создавать безопасные, эффективные и легко управляемые конвейеры обработки данных. Configuration center позволяет быстро генерировать ETL‑логику, используя custom template и удобные developer‑assisting features. Встроенная функция маскирования конфиденциальной информации помогает защищать учётные данные пользователей и другие конфиденциальные данные. Вы также можете тонко настраивать параметры конвейера, такие как конкурентность и буферизация, чтобы удовлетворять разнообразные требования к производительности и пропускной способности.
Logstash configuration file определяет конвейер, состоящий из трёх этапов:
Для получения дополнительной информации см. официальную документацию Logstash Plugins.
Parameter | Description |
|---|---|
Name | Имя пользовательского файла конфигурации. Он может содержать только буквы, цифры, дефисы (-) и подчёркивания (_), и должен начинаться с буквы. Минимальная длина — 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 | Максимальное время в миллисекундах, которое рабочий процесс pipeline ждёт новое событие, пока текущая партия ещё не заполнена. Единица: ms Уменьшите значение этого параметра, когда в приоритете производительность в реальном времени. |
queue.type | Надёжность данных | memory | Настраивает внутреннюю очередь для буферизации событий.
|
queue.checkpoint.writes | Чекпоинт | 1024 (рекомендовано) | Максимальное количество записанных событий до принудительного чекпоинта. Этот параметр необходимо задавать только когда queue.type установлен в persisted. |
queue.max_bytes | Disk-based queue | 1024 (recommended) | Общая емкость persistent queue.
Единица: MB |
Вы можете редактировать существующие файлы конфигурации, установить файл конфигурации в качестве пользовательского шаблона и удалять файлы конфигурации.
Operation | Constraints | Руководство по операции |
|---|---|---|
Изменение файла конфигурации | Файл конфигурации, для которого запущена задача pipeline, нельзя изменить. | В списке файлов конфигурации найдите строку, содержащую файл конфигурации, который вы хотите отредактировать, и нажмите Edit в столбце Operation. Измените файл в соответствии с новыми требованиями или исправьте ошибки. |
Установка файла конфигурации в качестве шаблона | N/A | В списке файлов конфигурации нажмите Add to Custom Template в столбце Operation. В открывшемся диалоговом окне задайте имя шаблона, описание и содержимое файла конфигурации, затем нажмите OK. После этого его можно будет использовать в качестве шаблона для последующей настройки файлов конфигурации. |
Резервное копирование файлов конфигурации | N/A | Нажмите |
Удаление файла конфигурации |
| В списке файлов конфигурации найдите строку, содержащую файл конфигурации, который вы хотите удалить, и нажмите Delete в столбце Operation. В открывшемся диалоговом окне введите DELETE, а затем нажмите OK для подтверждения удаления. |