12.1. 安装

备注

以下示例要求在环境中设置版本:

$ export TAG="4.0.2"
$ export VERSION="2.12-${TAG}" # note: 2.12 is the Scala build version

12.1.1. 拿到处理器

备注

有适用于Scala 2.12和2.13的GeoMesa Nars。通常,这仅在使用用Scala编写的自定义GeoMesa转换器模块时才相关。否则,只要给定NiFi中的所有GeoMesa Nar使用相同的Scala版本,这两个版本都可以使用。

可从下载GeoMesa NiFi处理器 GitHub

或者,您也可以从源代码构建处理器。首先,从GitHub克隆项目。在您的计算机上选择一个合理的目录,然后运行:

$ git clone https://github.com/geomesa/geomesa-nifi.git
$ cd geomesa-nifi

要构建该项目,请运行:

$ mvn clean install

NAR包含捆绑依赖项。要更改依赖项版本,请修改版本属性 (<hbase.version> 等)中的 pom.xml 在建造之前。

12.1.2. 安装处理器

要安装GeoMesa处理器,您需要将NAR文件复制到 lib 您的NiFi安装目录。有两个常见的NAR文件和七个数据存储区特定的NAR文件。

常见NAR文件:

  • geomesa-datastore-services-api-nar_$VERSION.nar

  • geomesa-datastore-services-nar_$VERSION_.nar

数据存储区NAR文件:

  • geomesa-hbase1-nar_$VERSION.nar -HBase 1.4

  • geomesa-hbase2-nar_$VERSION.nar -HBase 2.5

  • geomesa-accumulo20-nar_$VERSION.nar -Acumulo 2.0

  • geomesa-accumulo21-nar_$VERSION.nar -Acumulo 2.1

  • geomesa-gt-nar_$VERSION.nar -邮政地理信息系统

  • geomesa-kafka-nar_$VERSION.nar 卡夫卡2.8

  • geomesa-redis-nar_$VERSION.nar Redis 7

  • geomesa-fs-nar_$VERSION.nar Hadoop 2.10

  • geomesa-lambda-nar_$VERSION.nar Kafka 2.8(Lambda架构)

所有数据存储区都需要通用NAR文件。可以根据需要安装特定于数据存储区的NAR。

备注

有两个HBase和Acumulo Nar对应于不同的版本。确保为您的数据库选择适当的NAR。

如果您从GitHub下载了NAR:

$ export NARS="geomesa-hbase2-nar geomesa-datastore-services-api-nar geomesa-datastore-services-nar"
$ for nar in $NARS; do wget "https://github.com/geomesa/geomesa-nifi/releases/download/geomesa-nifi-$TAG/$nar_$VERSION.nar"; done
$ mv *.nar $NIFI_HOME/extensions/

或者,要在从源构建后安装NAR:

$ export NARS="geomesa-hbase2-nar geomesa-datastore-services-api-nar geomesa-datastore-services-nar"
$ for nar in $NARS; do find . -name $nar_$VERSION.nar -exec cp {} $NIFI_HOME/extensions/ \;; done