代码之家  ›  专栏  ›  技术社区  ›  Atanu chatterjee

Nifi Spark集成,不使用Kafka和Pyspark

apache-nifi pyspark apache-spark
  •  -1
  • Atanu chatterjee  · 技术社区  · 8 年前

    我想使用PySpark直接从Nifi输出端口读取数据到Spark流媒体(其间不使用Kafka)。我在Scala中看到的参考代码很少,使用“SiteToSiteClient”方法设置与Nifi的连接。但我无法获得任何等效的Python模块来用Python开发类似的代码。

    谁能帮帮我吗?

    谢谢

    1 回复  |  直到 8 年前
        1
  •  2
  •   Bryan Bende    8 年前

    您需要用Python实现自己版本的SiteToSiteClient。

    NiFi提供了Java实现:

    https://github.com/apache/nifi/tree/master/nifi-commons/nifi-site-to-site-client

    推荐文章
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号