問題タブ [apache-nifi]

NiFi v0.6.1 を使用して、バックアップ/アーカイブをインポートする方法はありますか?

POST /controller/archiveまた、バックアップとは、REST API または「コントローラー設定」(ツールバー ボタン) を使用して呼び出し、次に「バックアップ フロー」(リンク) を呼び出したときに生成されるファイルを意味します 。

バックアップを解凍してテンプレートとしてインポートしようとしましたが、うまくいきませんでした。しかし、それをエクスポートされたテンプレート ファイルと比較すると、フォーマットはかなり異なります。しかし、おそらくそれをテンプレートに変換する方法はありますか?

現時点での私の現在の回避策は、最上位フローでコンポーネントを選択せず​​、「テンプレートの作成」を選択することです。これにより、すべてのコンポーネントを含むテンプレートが追加されます。次に、それをエクスポートします。これに関する私の問題は、REST API を介して自動化するのが少し難しいことです。Fiddler を使用して UI が何をしているかを判断すると、最初にすべてのコンポーネント (ラベル、プロセッサ、接続など) を含むスニペットが生成されます。POST /nifi-api/contorller/templates次に、スニペット ID を使用してテンプレートの作成 ( ) を呼び出します。したがって、テンプレートの呼び出しは簡単ですが、スニペットの定義を生成するには少し手間がかかります。

注: 次の機能リクエストが実装されたら、代わりにそれを使用することを想定しています。

https://cwiki.apache.org/confluence/display/NIFI/Configuration+Management+of+Flows

私はApache Nifiにかなり慣れていません。SOAP ファイルを JSON に変換しようとしています。それを行う簡単な方法はありますか、それとも教えてくれるチュートリアルはありますか? SOAP ファイルとは、SOAP Web サービスで使用される xml ファイルを意味します。ありがとうございました

ファイルをフェッチし、テキストを抽出し、シェル スクリプトを実行するフローがあり、シェル スクリプトがハイブ スクリプトを実行します。(ファイルから日付を取得し、-hivevar として渡すだけです)。私のシェルスクリプトは次のようになります。

ハイブ スクリプトが完了し、データがテーブルに挿入されますが、ExecuteStreamCommand は無期限に実行され続け (1 は上隅に留まります)、nifi を再起動する必要があります (これを処理するより良い方法はありますか?)。

私はいくつかのことに気づきました：

• クエリのサイズを小さくすると (私のハイブ クエリはユニオンの数です)、ExecuteStreamCommand はハングしません。
• ジョブがハングすると、Resource Manager の AM はかなりの時間 (10 分程度) 実行中のままになります。1 つのコンテナーで Hive CLI Tez セッションを作成するときのようなものです。クエリのサイズを小さくしてもジョブがハングしない場合、AM はすぐに終了状態になります。- コマンド ラインを使用して完全なクエリまたはスクリプトを手動で実行すると、正常に動作します。
• 動作に一貫性がありません。ハングしない場合もあれば、ハングする場合もあります...(ほとんどの場合はハングします..)

何か案は？app.log またはアプリケーション ログに何も見つかりませんでした

ファイルをハイブに直接保存できるプロセッサが nifi にないことに気付きました。これに役立つプロセッサの組み合わせはありますか、それともそれを行うことができる利用可能なテンプレートはありますか?

ありがとう。

HandleHttpRequest を使用する場合、同じハンドラーを介して異なるオブジェクトを操作する構造をセットアップしたいと考えています。

/api/foo/add/1/2..

それを簡単に解析するにはどうすればよいですか

?