Nifi ValideCSV架构示例

如何解决Nifi ValideCSV架构示例

我正在Nifi中尝试使用ValidateCSV处理器，但是我不知道如何定义架构。 我的输出（流文件）如下：

> PassCountId,CameraId,EventDate,Counter
> 
> 32340,4,2020-10-14 15:26:20.170,4
> 
> 32341,3,2020-10-14 15:26:51.747,4
> 
> 32342,2020-10-14 15:26:57.907,6

我尝试使用以下模式，但是没有用。

{
  "type": "record","name": "NifiRecord","fields" : [
    {"name": "PassCountId","type": "bigint"},{"name": "CameraId","type": "int"},{"name": "EventDate","type": "datetime"},{"name": "Counter","type": "int"}
  ]
}

定义架构的正确方法是什么？

我已经检查过文档。不幸的是，它没有帮助。 https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.ValidateCsv/

谢谢。

解决方法

@Tyr这是模式的示例

   "type" : "record","namespace" : "nifi","name" : "nifi","fields" : [

      { "name" : "c1","type" :  ["null","string"] },{ "name" : "c2","type" : ["null",{ "name" : "c3","string"] }

   ]

}

根据文档，您可以提供模式验证功能：

 : [ParseBigDecimal,ParseBool,ParseChar,ParseDate,ParseDouble,ParseInt,ParseLong,Optional,DMinMax,Equals,ForbidSubStr,LMinMax,NotNull,Null,RequireHashCode,RequireSubStr,Strlen,StrMinMax,StrNotNullOrEmpty,StrRegEx,Unique,UniqueHashCode,IsIncludedIn] 

我的建议是从字符串模式开始，然后在第一列中尝试使用ParseBigDecimal。进行小型可测试的迭代，直到拥有完整的架构为止。