様子は以下のコマンドで確認できます。UIはデフォルトではポートは8080になっています。conf/nifi.propertiesの中の以下の場所で変更することができます。StormやVue.jsなどよく使うアプリケーションで使うので8086に変更しました。アクセスしてみましょう。以下のような画面をみるかと思います。注意点としては、**すでにPort番号80xxを使っていた場合でもerrorは出ないので、Portが空いているかチェックしてから起動するようにしましょう。UIの各コンポーネントの名前は、参考文献から拝借してきました。Palletteです。ここからは実際に概念が重要となるために少し解説します。Nifiで管理するシステム間で移動するオブジェクトを表現する。ユーザーの一つ一つのデータである。二つの構成要素があって、実際のデータであるContentとメタデータであるkey:valueである。データのルーティング、変換、停止など実際の処理を行うものである。プロセッサー間で接続を提供する。スレッドをどのように接続して、管理するかをメンテナンスする。ブローカーとして動作する。プロセスの抽象的の集合ある。NifiのアーキテクチャとコンセプトNifiのアーキテクチャは以下のようになっています。Flowfileの実際のバイトが保存される場所である。来歴がすべて保存されている場所である。大体のところは解説しおえたので、実際にデータフローを作成してみます。Processorの作成Processorボタンをカンバスにドラッグして作成を始めます。すると以下のような画面がでるので、Filterの中でGetFileと打ってください。すると以下のように作成することができます。GetFileとは、ローカルからファイルを取得して、削除します。これからは特に間違って設定しないように注意しましょう。実際にProcessorは定義できたのですが、何も設定はしていません。Processorで定義しましょう。Palleteで歯車のアイコンを押すの二通りがあります。以下のように画面がでればおっけいです。Guideをご覧ください。使うまでの設定というと、Propertiesタグしか必要ありません。以下の画面で設定していきます。太文字の部分は、必須プロパティであり、それ以外はオプショナルです。各設定項目には、?でヘルプが付いているので、適宜参照するといいでしょう。デフォルトで設定されている項目はあまりいじるぢつようなないと思いますが、以下の項目だけ設定しておきましょう。Directoryです。Homeである/usr/local/Cellar/nifi/1.7.1/libexec以下にサンプルファイルを作成しました。$_そして、プロパティを設定しました。Processorを定義したあと、「そのデータをどのように使うのか」を考えます。ここでは、LogAttributeというFileFlowを出力するProcessorを作成します。作成のステップは先ほどと同様です。Connectionを作るProcessorができたら、Connectionを作っていきます。先ほど作成したProcessorはホバーすると緑色の矢印のアイコンが出るかと思います。それを二つのProcessorの間でドラッグして接続します。すると以下のようなConnectionの設定ファイルがでるでしょう。SETTIGSが重要です。BackPressureでは、Schedularがジョブを管理する中で、どのくらいキューがいっぱいになったら割り振らないかを設定できます。Prioritizersでキューがどの順番で動作するかを設定することができます。Addを押すと、以下のようにできているのがわかります。Barに赤で四角のアイコンが出たと思います。LogAttributeはデータが出る先としては何も接続されていないです。Terminateに設定してあげて、Flowfileの終点であることを示さなければなりません。すると今までLogAttributeは黄色の三角でしたが、赤い四角に変わっています。データフローを開始させるStartを押すことで開始させることができます。開始させると以下のようになります。GetFileが対象としているディレクトリに何もファイルが存在しないので、何もなりません。試しに二つのファイルを作成しました。input_b.txt空ファイルで2回ほど試したのでOutが4となっていますが、ただしく動作しています。まとめ今回は以上となります。Kubernetesのいろは。»プロフィール学生エンジニア。忘れてしまうので備忘録です。flaskでServerlessにホストするTelepresence概論スターをつけました引用をストックしましたストック一覧を見る閉じる引用するにはまずログインしてくださいログイン閉じる引用をストックできませんでした。再度お試しください閉じる限定公開記事のため引用できません。