0

我是 NiFi 的新手,假设我什么都不知道。我在本地安装了它,我尝试创建一个从 SFTP 获取一些文件并将它们传递给 AzureDataLake 的流。我使用 ListSFTP、FetchSFTP 和 PutAzureDataLakeStorage。然后我想在 Fetch 和 Put 之间放置一个 ValidateCsv。但是现在我有两个问题。

  1. 第一个是无论我创建什么流程,我都会运行一次,如果它有效,它就不再有效即使我关闭服务器和一切。我必须从头开始重新创建它才能进行下一次测试。我不知道为什么会这样,但这真的让我慢了下来

  2. 第二,我只想获取响应特定名称格式的文件(TAL_dddd_dddd_dddddddd.0 是 d 数字)。我所做的是列表,在Fetch 中,在其远程文件中放置类似./upload/NOMBRE/${filename:matches('TAL_\d{4} \d{4} \d{8}. 0')}。但它不起作用我打算用 ./upload/NOMBRE/${'TAL_\d{4} \d{4} \d{8}.0'}进行测试。但是,当然,问题 1 出现了,在重做整个流程之前,我来问。

我将不胜感激。非常感谢。

4

0 回答 0