ListGCSBucket
Описание
Получает список объектов из корзины GCS. Для каждого объекта, который перечисляется, создается FlowFile, представляющий объект, чтобы его можно было получить в сочетании с FetchGCSObject. Этот процессор предназначен для работы только на основном узле в кластере. Если основной узел изменится, новый основной узел продолжит с того места, где остановился предыдущий, не дублируя все данные.
Теги
google cloud, google, storage, gcs, list
Свойства
| Название | Описание |
|---|---|
| GCP Credentials Provider Service | Служба контроллера, используемая для получения учётных данных Google Cloud Platform. |
| Project ID | Google Cloud Project ID Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Bucket | Bucket of the object. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Prefix | Префикс, используемый для фильтрации списка объектов. В большинстве случаев он должен заканчиваться косой чертой ('/'). Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Listing Strategy | Укажите, как определять новые/обновленные объекты. Подробные описания стратегий см. в разделе «Стратегии». |
| Entity Tracking State Cache | Listed entities are stored in the specified cache storage so that this processor can resume listing across NiFi restart or in case of primary node change. 'Tracking Entities' strategy require tracking information of all listed entities within the last 'Tracking Time Window'. To support large number of entities, the strategy uses DistributedMapCache instead of managed state. Cache key format is 'ListedEntities::{processorId}(::{nodeId})'. If it tracks per node listed entities, then the optional '::{nodeId}' part is added to manage state separately. E.g. cluster wide cache key = 'ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b', per node cache key = 'ListedEntities::8dda2321-0164-1000-50fa-3042fe7d6a7b::nifi-node3' The stored cache content is Gzipped JSON string. The cache key will be deleted when target listing configuration is changed. Used by 'Tracking Entities' strategy.This Property is only considered if the [Listing Strategy] Property has a value of "Tracking Entities". |
| Entity Tracking Initial Listing Target | Specify how initial listing should be handled. Used by 'Tracking Entities' strategy.This Property is only considered if the [Listing Strategy] Property has a value of "Tracking Entities". |
| Entity Tracking Time Window | Specify how long this processor should track already-listed entities. 'Tracking Entities' strategy can pick any entity whose timestamp is inside the specified time window. For example, if set to '30 minutes', any entity having timestamp in recent 30 minutes will be the listing target when this processor runs. A listed entity is considered 'new/updated' and a FlowFile is emitted if one of following condition meets: 1. does not exist in the already-listed entities, 2. has newer timestamp than the cached entity, 3. has different size than the cached entity. If a cached entity's timestamp becomes older than specified time window, that entity will be removed from the cached already-listed entities. Used by 'Tracking Entities' strategy. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Entity Tracking Initial Listing Target] Property has a value of "Tracking Time Window". |
| Record Writer | Указывает средство записи, которое будет использоваться для создания списка. Если не указано иное, для каждого объекта, включенного в список, будет создан один потоковый файл. Если указано средство записи, все объекты будут записаны в один потоковый файл вместо добавления атрибутов к отдельным потоковым файлам. |
| Use Generations | Указывает, следует ли использовать поколения GCS, если применимо. Если значение равно false, будет возвращена только последняя версия каждого объекта. |
| Number of retries | How many retry attempts should be made before routing to the failure relationship. |
| Storage API URL | Overrides the default storage URL. Configuring an alternative Storage API URL also overrides the HTTP Host header on requests as described in the Google documentation for Private Service Connections. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Proxy Configuration Service | Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: HTTP + AuthN |
Взаимосвязи
- success: FlowFiles are routed to this relationship after a successful Google Cloud Storage operation.