EqualumのFS機能を試す！（検証編1）

####前回の投稿で、何とか無事に環境と道具は揃いましたので、今回から本題のEqualumのファイルシステム機能を検証していくことにします。基本的な手順や作業は以前のEqualum検証と同じですので、宜しければ以前の投稿を参考にして頂ければと思います。

##取り急ぎFSが使えるようにEqualumを設定します
Equalumのダッシュボード上で**SOURCES**部分にある**+ADD**ボタンを選択します。

![スクリーンショット 2021-12-12 9.18.35.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/ca998315-f930-a493-3b4a-9f9b0d366b92.png)

メニューからFilesを選択します。

![スクリーンショット 2021-12-12 9.18.57.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/2aa39245-d5f9-482b-1d84-1682e1b93f51.png)

以前のEqualum検証と同じ様に必要事項を設定していきます。

![スクリーンショット 2021-12-12 9.19.07.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/d5a0ad83-045a-1ab8-d3a1-d39870ff57b4.png)

**Agent Location**は選択可能なプルダウンメニューが出てきますので適宜選択します。

![スクリーンショット 2021-12-12 11.24.09.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/96874053-0ad4-3c29-8f3a-375d3d81346f.png)

基本的にデータソースとしてファイルシステムが利用出来る事前準備はこれで終了です。

![スクリーンショット 2021-12-12 9.20.11.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/a8828432-51f4-3d09-8b27-28de2bf678c1.png)


##イベントストリームが使えるように情報を設定する
次に、どのディレクトリを利用するか等の設定を行います。
先程のダッシュボード上で**+ADD**ボタンを選択します。

![スクリーンショット 2021-12-12 9.21.54.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/7d580bf7-2b7d-c83d-b1fe-6f17b3200cbf.png)

必要事項を設定します。**Full Path to file Directory**には**準備編**で設定した情報を設定します。最後の**/**を忘れるとエラーで叱られますので注意が必要です。

![スクリーンショット 2021-12-12 9.23.22.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/1b2aae4f-4018-2e8b-8e66-22ab8f9104ce.png)

##EqualumのノーコードFLOWを作成する
以前の検証と同じ様にEqualumが指定されたディレクトリにCSVファイルの到着を起点にFLOW処理を行う検証を行います。

基本的には、同じ作業を順番に行えば問題無くストリーミングFLOWが動きますので、今回は**CSV特有の事前処理**の部分だけ追記の形で書かせて頂きました。

![スクリーンショット 2021-12-12 9.23.48.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/f5840ccc-b2d5-32ef-0307-a1c2bcfdfa15.png)

**FLOWS**にある**+ADD**ボタンを選択しGUIエディタに入ります。

![スクリーンショット 2021-12-12 9.24.05.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/94f302df-0aff-ce92-a893-2002b40fd468.png)

メニューから**Event Stream**を選択して先程設定した情報を選択します。

![スクリーンショット 2021-12-12 11.37.11.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/8185425f-6282-3f66-e824-a4e2bd0e8dc9.png)

最初にCSVファイルの情報をデータベースで使える様に、必要なカラム属性の確認と設定をGUI上で行います。

・・とは言っても、作業自体は非常に簡単で・・**Transform**を先程のEvent Streamに接続します。

![スクリーンショット 2021-12-12 11.39.03.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/bf0ff454-e137-de9a-ed1d-244dc042fbea.png)

初期の段階では、CSV側の情報を文字列として認識しますので、ここで必要な型変換を行っておきます。

![スクリーンショット 2021-12-12 9.25.09.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/5c5314c9-0357-d194-7347-93a450b90bc0.png)

作業は必要なカラム名をダブルクリックして中央に選択されたカラム名に続いて**::xxxxxx**と属性を書いていきます。

![スクリーンショット 2021-12-12 9.25.28.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/e0e8f048-7f86-48a9-48e5-8c78c19edf06.png)

![スクリーンショット 2021-12-12 9.25.51.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/62af574e-0039-2ac1-6e93-5af4a7182a12.png)

この作業を最初に行う事で、以降のFLOWデザインにおいて各カラム情報は、以前の検証と同様に利用する事が出来る様になります。

因みに・・・今回作成したCSVファイル・ストリーミング処理はこんな感じになります。

![スクリーンショット 2021-12-12 9.33.40.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/197589/1807dc52-7784-e681-e684-539cf32650d3.png)

後は、名前を付けてセーブしてシステム上に展開し、通常の手順で起動すればOKです。

##今回のまとめ
今回は、Equalumを実際に使ってCSVファイルを使用したファイルシステム機能の検証・前半戦を書かせて頂きました。

ポイント的には、CSV等の文字列ファイルを読み込む場合に、忘れずに**必要な属性の変更（キャスト）作業を行う事**・・という作業を忘れない様に実施しておく・・・という部分になります。

次回は、実際にPythonで作成したツールを動かし、架空の物販データを流してCSVファイル生成、転送、Equalumのストリーミング処理・・・の流れを検証したいと思います。