우리는 NiFi에서 일부 플로우를 생성하고 있으며 큐가 빌드되고 있지만 어떤 이유로 인해 플로우가 예상대로 작동하지 않는 경우가 있습니다. 하루가 끝나면 대기열을 지우고 어떻게 든 자동화하려고합니다. 문제는 백엔드에서 대기열을 어떻게 삭제할 수 있는가하는 것입니다. 우리가 달성 할 수있는 방법이 있습니까?
csv 데이터를 json 값으로 변환해야합니다. 내 CSV 데이터는 아래와 같습니다. aa cc dd ee ff
cc dd ff gg hh ll mm nn oo pp
H1 "null" H3 "null" H5 H6 H7
c1 c2 c3
c4 c5 c6 c7 c8 c9 c10 c11 c12
"H1"행 데이터 만 가져 오면 csv 파일에있
xml로 내보내는 NiFi 템플릿이 있습니다. rest-api를 사용하여 템플릿을 NiFi 인스턴스에 업로드합니다. 이제는 rest-api (또는 프로그래밍 방식으로 사용 가능한 다른 옵션)에서 템플릿의 일부 속성 (예 : 비밀번호)을 업데이트/추가하려고합니다. 문서 및 다양한 커뮤니티 스레드를 성공없이 읽었습니다. 참조 링크 : 어떤 접근 방식 How t
Crate 데이터베이스는 DBCPConnectionPool 컨트롤러 서비스를 사용하여 Nifi에서 Crate에 연결할 수 있어야하는 jdbc 드라이버를 제공합니다. 그래서, 내가 연결을 얻을했다의 ConvertJSONToSQL 프로세서는 나무 상자 데이터베이스에서 열을 얻을 수 있지만, 나는 다음과 같은 오류를 얻을 PUTSql 프로세서에 도착하면 : Fl
스파크 스트리밍을 사용하여 보안 클러스터에서 Nifi의 데이터를 읽으려고합니다. SSLContext를 사용하여 SiteToSiteClient에 SSLContext를 추가하여 인증하지만 SSLContext는 직렬화 할 수 없습니다. 내 코드는 다음과 같습니다 def main(args: Array[String]) {
val pKeyFile = ne
저는 Nifi-0.6.1을 GetFile + SplitText + ReplaceText 프로세서 조합으로 사용하여 30MB (300 000 행)의 csv 데이터를 분할했습니다. GetFile은 30mb를 매우 빠르게 SplitText에 전달할 수 있습니다. 에서 SpliText + Replace Text에서 데이터를 Json으로 분할하는 데 25 분이 걸립
Apache NIFI를 사용하기 시작했습니다. 'GetFile'프로세서를 사용하여 원격 네트워크에서 파일을 가져 오는 것입니다. 첨부 된 컴퓨터를 로컬 디스크에 연결했는데 프로세서 설정에서 구성하는 방법을 모르겠습니다.이 질문에 대한 문서를 찾을 수 없습니다. 감사합니다. 감사합니다.
저는 Nifi의 표현 언어를 사용하여 2 개의 날짜를 계산하여 템플릿에 적용합니다. 나는이 날짜를 한 번 계산하고 필요한만큼 템플릿에 사용하는 것을 좋아합니다. 내 생각은 그런 짓을하는 것입니다 dateStart = ${now():toNumber():minus(86400):format("YYYY-MM-dd'T'hh:mm:'00'")}
내가 var에에 식