MoveAzureDataLakeStorage
MoveAzureDataLakeStorage
Azure Data Lake Storage Gen 2 내에서 콘텐츠를 다른 위치로 이동시키는 프로세서예요. 이동 후에는 원본 위치에서 파일이 더 이상 존재하지 않게 돼요.
본문
번들 (Bundle)
org.apache.nifi | nifi-azure-nar
설명
Azure Data Lake Storage Gen 2 내에서 콘텐츠를 이동해요. 이동 후에는 파일이 원본 위치에서 더 이상 사용할 수 없어요.
태그
adlsgen2, azure, cloud, datalake, microsoft, storage
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| ADLS Credentials | Azure 자격 증명을 얻기 위한 Controller Service예요. |
| Conflict Resolution Strategy | 출력 디렉터리에 같은 이름의 파일이 이미 있을 때 어떻게 처리할지 나타내요. |
| Destination Directory | 파일이 이동될 Azure Storage 디렉터리 이름이에요. 디렉터리 이름은 앞에 '/'를 포함할 수 없어요. 빈 문자열 값으로 루트 디렉터리를 지정할 수 있어요. 존재하지 않는 디렉터리는 생성돼요. 원래 디렉터리 구조를 유지해야 한다면 대상 디렉터리 뒤에 전체 경로를 제공해야 해요. 예: destdir/${azure.directory} |
| Destination Filesystem | 파일이 이동될 Azure Storage 파일 시스템 이름이에요. |
| File Name | 파일 이름이에요. |
| Source Directory | 이동이 시작될 Azure Storage 디렉터리 이름이에요. 디렉터리 이름은 앞에 '/'를 포함할 수 없어요. 빈 문자열 값으로 루트 디렉터리를 지정할 수 있어요. |
| Source Filesystem | 이동이 시작될 Azure Storage 파일 시스템 이름이에요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요. SOCKS의 경우 선택한 SOCKS 버전이 프로세서에서 사용된다는 보장은 없어요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
failure |
어떤 이유로 Azure Storage에 쓸 수 없었던 파일이 이 관계로 전달돼요. |
success |
Azure Storage에 성공적으로 쓰인 파일이 이 관계로 전달돼요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
azure.source.filesystem |
원본 Azure 파일 시스템 이름이에요. |
azure.source.directory |
원본 Azure 디렉터리 이름이에요. |
azure.filesystem |
Azure 파일 시스템 이름이에요. |
azure.directory |
Azure 디렉터리 이름이에요. |
azure.filename |
Azure 파일 이름이에요. |
azure.primaryUri |
파일 콘텐츠의 기본 위치예요. |
azure.length |
Azure 파일의 길이예요. |
더 보기 (See also)
org.apache.nifi.processors.azure.storage.DeleteAzureDataLakeStorageorg.apache.nifi.processors.azure.storage.FetchAzureDataLakeStorageorg.apache.nifi.processors.azure.storage.ListAzureDataLakeStorage