nifi 예제

안녕하세요, R로 작성된 전처리 코드가 있고 ExecuteStreamCommand을 사용하여 nifi를 사용하여 가져온 데이터에서이 코드를 실행하려고합니다. 내 R 스크립트를 실행 하기 위해 ExecuteStreamCommand에서 제공 해야 하는 입력 확실 하지 않습니다. 당신은이 저를 도울 수 있습니까? 각 줄은 사용 가능한 JCE 정책에 따라 키 ID를 정의한 다음 16바이트 IV및 래핑된 AES-128, AES-192 또는 AES-256 키의 Base64 인코딩된 암호 텍스트를 정의합니다. 개별 키는 conf/bootstrap.conf에서 nifi.bootstrap.sensitive.key로 정의된 마스터 키를 사용하여 AES/GCM 암호화로 래핑됩니다. 초기 시드 URL을 받는 템플릿은 사이트의 내용을 스크랩하여 더 많은 URL을 생성합니다. 각 URL에 대해 특정 구와 일치하는 줄을 추출합니다(예제에서 «nifi»)는 FlowFile을 주소로 전자 메일로 보송합니다. 또한 웹 사이트를 함께 번들로 묶은 다음 압축하여 로컬 폴더에 넣습니다. 참고: 이 템플릿을 실행하려면 기본값이 있는 분산MapCacheServer가 필요합니다. 생성 당시에는 프로세서가 없는 컨트롤러 서비스를 명시적으로 포함할 방법이 없었기 때문에 포함되지 않습니다. 나는 입력 프로세서와 출력 프로세서, 생성 FlowFile 및 PutFile와 NiFi 무엇인지 보여주기 위해 매우 간단한 예를 도입했다. 기본 단계는 적절한 프로세서를 추가하고 연결한 다음 실행하는 것입니다. NiFi가 NiFi 레지스트리에 연결되면 데이터 흐름은 프로세스 그룹 수준에서 버전 제어될 수 있습니다. NiFi 레지스트리 사용 및 구성에 대한 자세한 내용은 https://nifi.apache.org/docs/nifi-registry-docs/index.html 설명서를 참조하십시오.

참고: 이 템플릿을 사용하려면 노드에서 사이트 간 을 사용하도록 설정해야 합니다. 이렇게 하려면 $NIFI_HOME/conf/nifi.properties 파일을 열고 «nifi.remote.input.port» 속성을 일부 열린 포트 번호로 설정하고 «nifi.remote.input.secure»를 «false»로 설정합니다(물론 보안 환경에서 실행중인 경우제외). 사이트 간 사이트에 대한 자세한 내용은 사용 설명서의 사이트 간 섹션을 참조하십시오. 예를 들어 특정 FlowFile이 수신되었는지 확인하려면 이벤트 유형인 «RECEIVE»를 검색하고 Uuid 또는 파일 이름과 같은 FlowFile에 대한 식별자를 포함합니다. 별표(*)는 임의의 수의 문자에 대해 와일드카드로 사용할 수 있습니다. 따라서 2015년 1월 6일에 파일 이름에 «ABC»가 있는 FlowFile이 언제든지 수신되었는지 여부를 확인하기 위해 다음 이미지에 표시된 검색을 수행할 수 있습니다. 지리적 위치를 결정하기 위해 경도 조회. 위도 및 경도 값은 들어오는 레코드에 있으며 LookupRecord의 동적 속성은 위도/긴 필드를 «찾아서» ScriptedLookupService에 전달하도록 제공됩니다.