当前位置: 首页 > 知识库问答 >
问题:

在 NiFi 中生成 UUID5

宦树
2023-03-14

在 NiFi 中,我有一个带有属性 RSID 的流文件。我需要基于 RSID 生成一个 UUID v5,并将其作为属性添加到流文件中。此 uuid 需要基于 RSID,因为某些报告将具有相同的 RSID因此需要具有相同的 UUID5。

我在Groovy中看到一些方法会生成随机uuid,但不是v5也不是基于字符串。这在Groovy/NiFi中可以做到吗?如果可以,这将如何完成?我对Groovy很陌生。

共有1个答案

翟黎明
2023-03-14

您确实可以使用ExecuteScript处理器在Groovy和NiFi中做到这一点。这篇SO帖子包括生成UUID v5的代码,您可以将它应用到您的< code>RSID名称空间。如果你想要一些关于使用ExecuteScript的NiFi API的指导,请随意查看我的烹饪书系列,希望它能帮助你组装一个工作解决方案。

我还编写了一个Jira,将UUID5函数添加到NiFi表达式语言中,以使这更容易。

 类似资料:
  • 我以前从未使用过 Jolt Transform,我不确定如何修复我所做的,所以如果这实际上是一个非常容易的修复,我深表歉意。 我有两个XML文件(下面的虚拟版本,实际包含PII),我在NiFi中使用MergeRecord合并在一起。由于输出的方式(一个带有 JSON 数组的流文件),建议我使用 JoltTransform 将它们正确地合并在一起。有人指出了这个问题,即如何在 NiFi 中进行流式连

  • 有一个特定的处理器,正如下面提到的,我对它感兴趣,与1.2.0相比,1.5.0中有一个额外的特性,所以我想使用它。 我看到有两种方法。 以上处理器存储为nifi-standard-nar-x.x.x.nar-unpacked文件。所以只需从1.5.0复制Nar,并将其放在1.2.0上即可。在此之后,我不确定nifi是否会识别这个新的处理器版本? 上面的处理器是下面文件的一部分,因此从它中创建一个新

  • 我想把Nifi flowfile发送到Spark,在Spark中做一些转换,然后再把结果发送回Nifi,这样我就可以在Nifi中进行进一步的操作。我不想写flowfile写到数据库或HDFS,然后触发火花作业。我想直接将flowfile发送到Spark,并直接从Spark接收到NIFI的结果。我尝试在Nifi中使用ExecuteSparkInteractive处理器,但我被卡住了。任何例子都是有帮

  • 我想使用NiFi rest api将flowfiles传输到输入端口。我浏览了NiFi rest api文档,发现似乎有支持来实现同样的功能。但是,说实在的,不是很清楚,也不是很详细。 我想知道的是,如何将排队的流文件从源处理器组传输到目标处理器组的输入端口,以便使用存储。 我想尝试点击以下endpoint:

  • 我正在尝试生成我的第一个.apk,并且在过去几天中遇到了错误。我在stack overflow和github上搜索ans,但没有任何帮助 根据这里的说明,我可以构建调试版本,但是当运行<code>gradlew assembleerelease</code>时,我会出错 E:\p1\placementScript\android\app\build\intermediates\res\merged

  • 是否有方法重写build方法返回SampleClass以避免执行build.build?