Путь данных на Google Cloud Platform для NiFi - PullRequest
0 голосов
/ 27 марта 2019

Я хочу указать местоположение input folder в GetFile процессоре в NiFi. Указанный мною путь неверен в соответствии с NiFi. Это все еще показывает предупреждающий знак. Я перешел по этой ссылке , но это не могло помочь. Ниже мой путь, который я использовал в свойстве input path в GetFile процессоре:

/browser/<bucket-name>/

Я даже попробовал ниже ссылки

gs://<bucket-name>

или

gs://browser/<bucket-name>

Никто из них не помог.

Как предложил Шу, я создал один ListGCSBucket процессор и создал для него новый GCPCredentialsService, но когда я запустил этот процессор, он выдает ошибку: com.google.cloud.storage.StorageException: Not Found за ведро. Ниже приведены мои несколько настроек: Подробности процессора:

enter image description here enter image description here

GCSControllerService Подробности: enter image description here enter image description here

На последнем изображении я не могу изменить значения на true. Итак, вот мои полные данные. Пожалуйста, укажите, где я иду не так. Любая помощь очень ценится.

1 Ответ

2 голосов
/ 27 марта 2019

По комментариям на вопрос.

GetFile процессор ищет input path, который указал на всех установленных узлах NiFi .

Используйте ListGCSBucket + FetchGCSObject процессоров для получения данных из GoogleCloudPlatform.

Для получения дополнительной информации см. , это и , это ссылки для использования процессоров list + fetch в nifi.

...