apache-nifi

0熱

1答えて

NiFi 1.4からはじまったばかりです。パイプ区切りのメッセージをkafka経由でHiveに送信しようとしています。だから私はConsumeKafkaRecord_0_10とPutHivStreamingプロセッサを使用しています。カフカリーダーを消費して、成功したデータをPutHiveStreamingに送信します。はアブロ形式でカフカリーダー書き込みデータを消費けどPutHiveStre

-1熱

1答えて

Hiveテーブルのデータをnifi経由のkafkaトピックに入れよう

私はHiveにいくつかのテーブルを用意しています。私の目標はそれらのビューを作成し、それをApache NiFiを通してKafkaのトピックに公開することです。これを行うにはどうすればよいですか？私はNifiを通じてやる予定です。

0熱

1答えて

NiFi一致flowfilesは

私はNiFiから2 flowfilesを持っています。上の例では、それは一致です！私はNiFiを使ってフローファイルを比較し、この接続を把握できますか？そうでない場合は、これを行うにはどうすればよいでしょうか？これを達成するためにどのようなツールや技術を検討すべきですか？ありがとうございます！

0熱

1答えて

Nifi - Rest APIによるリモートプロセスグループの更新

テンプレートを使用して、2つのnifiクラスタ間でデータ転送ジョブをパッケージ化しています.1つは送信者、もう1つは受信者です。私たちの仕事の1つにはリモートプロセスグループが含まれていて、テンプレートが作成された時点で問題なく動作していました。私たちの環境（dev、test、pre、prod）を使ってテンプレートをデプロイすると、手動で削除して、ユーザーインターフェイスでリモートプロセスグルー

0熱

1答えて

NifiでSolrを更新

SolrからURLを取得し、このソーシャルメディアの共有数を計算するNifiワークフローがあります。この共有数をSolrで更新する必要があります。フローファイルの2つの属性はURLとそれぞれの人数、どのようにNifiとsolrに更新を行うことができます。

0熱

1答えて

Nifiカールは

がどのように以下のカールリクエストはNifi カール-X POST -H「のContent-Type：アプリケーション/ JSON」を介してドキュメントに部分更新を行うためにSolrのために作るために要求「」/更新http://xxxx.xxxx.xxxxx/solr/ - -dataバイナリ ' [{ "URL"： "https://community.macmillan.org.uk/canc

2熱

1答えて

Apache Nifiを使用して電子メールの本文を読む

Apache Nifiを使用してシングルステップで電子メールの本文内容、電子メールヘッダーの詳細、電子メールの添付ファイルを取得することは可能ですか？もし私がこれを達成する方法を手伝ってください。

0熱

1答えて

Nifi org.apache.thrift.transport.TTransportException

私はNifi 1.4.0とHive 2.3.0を持っています。 Metastore Serviceは正常に動作していますが、何らかの理由でNifiがPutHiveStreaming Processorを実行できません。以下は完全なスタックです。これに関するどんな考えですか？ ApacheのNiFi 1.4.0で at org.apache.nifi.processors.hive.PutHiv

-1熱

1答えて

nifiがSQLServerExpressに接続できません

nifiからSQLSERVEREXPRESS 2017に接続しようとしています。以下のパラメータを使用してDBCP接続プールを作成しました。 DBCP Properties しかし、私はは、ExecuteSQLプロセッサを実行すると、以下のエラーを取得しておきます。このエラーを修正する Error すべてのヘルプは最大限使用されるであろう。私が実行していますのWindows 10 のJava

-2熱

1答えて

Nifi：groovyのファイル属性を処理する方法

特定の条件がフルフィルされる場合にはいくつかの属性を記述する必要がありますが、 'else'句のみをフルフィルしなければならない場合オプションは、他のブロックに書き込みを行い、私は変更hsould何を、ここに私のコード import org.apache.commons.io.IOUtils import java.nio.charset.StandardCharsets def flowFi