Apache NiFi - Происхождение данных
Apache NiFi регистрирует и сохраняет всю информацию о событиях, происходящих с принятыми данными в потоке. В репозитории происхождения данных хранится эта информация и предоставляется пользовательский интерфейс для поиска этой информации о событии. Доступ к данным можно получить для полного уровня NiFi и уровня процессора.
В следующей таблице перечислены различные поля в списке событий NiFi Data Provenance со следующими полями:
S.No. | Имя поля | Описание |
---|---|---|
1 | Дата / время | Дата и время события. |
2 | Тип | Тип события, например "СОЗДАТЬ". |
3 | FlowFileUuid | UUID потокового файла, для которого выполняется событие. |
4 | Размер | Размер потокового файла. |
5 | Название компонента | Имя компонента, выполнившего событие. |
6 | Тип компонента | Тип компонента. |
7 | Показать родословную | В последнем столбце есть значок show lineage, который используется для просмотра происхождения потокового файла, как показано на изображении ниже. |
Чтобы получить дополнительную информацию о мероприятии, пользователь может щелкнуть значок информации, присутствующий в первом столбце пользовательского интерфейса NiFi Data Provenance.
В файле nifi.properties есть некоторые свойства, которые используются для управления репозиторием NiFi Data Provenance.
S.No. | Имя свойства | Значение по умолчанию | Описание |
---|---|---|---|
1 | nifi.provenance.repository.directory.default | ./provenance_repository | Чтобы указать путь по умолчанию для источника данных NiFi. |
2 | nifi.provenance.repository.max.storage.time | 24 часа | Чтобы указать максимальное время хранения данных NiFi. |
3 | nifi.provenance.repository.max.storage.size | 1 ГБ | Чтобы указать максимальное хранилище данных NiFi. |
4 | nifi.provenance.repository.rollover.time | 30 секунд | Чтобы указать время обновления источника данных NiFi. |
5 | nifi.provenance.repository.rollover.size | 100 МБ | Чтобы указать размер ролловера источника данных NiFi. |
6 | nifi.provenance.repository.indexed.fields | Тип события, FlowFileUUID, Имя файла, Идентификатор процессора, Отношение | Чтобы указать поля, используемые для поиска и индексации источника данных NiFi. |