代码之家  ›  专栏  ›  技术社区  ›  watery

如何通过MongoDB查询结果有条件地处理流文件?

apache-nifi
  •  0
  • watery  · 技术社区  · 6 年前

    我需要根据MongoDB查询的结果处理文件列表,但我找不到任何处理器允许我这样做。我基本上必须根据涉及该文件属性的查询结果,获取每个文件并对其进行处理或完全丢弃。

    我在NiFi 1.50中看到的唯一与MongoDB相关的处理器是GetMongo,它显然不能接收连接,但只能根据配置的参数发出流文件。

    我找错地方了吗?

    1 回复  |  直到 6 年前
        1
  •  1
  •   mattyb    6 年前

    NIFI-4827 是一种改进的Jira,旨在允许GetMongo接受传入的流文件,内容将包含查询,属性将接受表达式语言。该代码仍在审查中,但目的是使其在即将发布的NiFi 1.6.0版本中可用。

    同时,作为一种可能的解决方法,如果您可以使用REST API InvokeHttp 手动调用并分析结果。此外,如果您有一个用于MongoDB的JDBC驱动程序(如Unity),那么您可以使用 ExecuteSQL .

    推荐文章
    venkata  ·  在Nifi中,FirstInfirstOutpriorizer和OldestFlowFileFirstPriorizer之间的区别是什么
    6 年前
    Sateesh Telaprolu  ·  nifi是否支持将单个流文件传输到处理器中的多个关系?
    6 年前
    Arnab Biswas  ·  Apache Nifi慢速群集问题
    6 年前
    Prabhu Bentick  ·  Apache nifi和pentaho端口问题
    6 年前
    Atanu chatterjee  ·  Nifi Spark集成,不使用Kafka和Pyspark
    6 年前
    Samuel Miller  ·  群集上的Nifi 1.5不受信任代理
    6 年前
    data_addict  ·  针对多个流文件的单一通知邮件Nifi
    6 年前
    MiamiBeach  ·  是否可以在WildFly上部署Apache Nifi?
    6 年前
    Gaurang Shah  ·  NIFI查询数据库组织。阿帕奇。阿夫罗。SchemaParseException:COUNT(*)中的非法字符;
    6 年前
    watery  ·  如何通过MongoDB查询结果有条件地处理流文件?
    6 年前
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号