アクションは、データがsenderに到着したときにトリガーするアクションを定義するために使用されます。ルールは、これらのアクションがトリガーされる状況を定義するために使用されます。 自動化アクション自動化されたアクションを使用することにより、ユーザーはデータをどのように処理するかを選択します。言い換えれば、それらは何を出力すべきかを選択します。利用可能な6つの異なるアクションがあります: - BellaDati REST
- データをBellaDatiに一括送信
- リモートデータベースに送信
- ファイルに保存
- MQTT publish
- Eメール
- HTTP リクエスト
- TCP/IP publish
ユーザーは1つ以上のアクションを選択できます。各アクションを複数回使用することができます(IoT Data Controller 1.2以降)。 送信者が5回連続でアクションを実行できなかった場合、その動作を一時停止します。その後、10分ごとに動作を再開し、自動化されたアクションを再度実行しようとします。 自動化アクションの追加アクションを追加するには、ユーザーは[新しいアクション]をクリックし、使用するアクションのタイプを選択して、[続行]をクリックする必要があります。一部のタイプのアクションでは、さらに構成が必要です (以下を参照)。
自動化アクションの削除自動化されたアクションを削除するには、ユーザーは アイコンをクリックして削除を確認する必要があります。
操作を終了するには、ユーザーは[適用]をクリックして変更をsenderに保存する必要があります。
BellaDati RESTこのアクションは、REST APIを介してデータをBellaDatiデータセットに送信します。このアクションを使用できるようにするには、接続パラメーターとマッピングを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | 接続 パラメーター | 説明 |
---|
URL | IPアドレス または BellaDatiのURL | Use SSL | SSLを有効にします | Consumer Key | ドメインで定義されたコンシューマキー。ドメインでOAuthを有効にする必要があります。 Learn more. | | ドメインで定義されたコンシューマシークレット。ドメインでOAuthを有効にする必要があります。 Learn more. | Username | BellaDatiユーザーのユーザー名 | Password | BellaDatiユーザーのパスワード | Continue on error | このトグルは、データの送信が失敗した場合のsenderの動作に影響を与えます。 無効にすると、未処理のデータはreceiverから削除されず、同じデータに対してアクションが再度トリガーされます。 有効にすると、データはreceiverから削除され、新しいデータが到着するまでアクションはトリガーされません。 このオプションは、データの送信中にアクションが失敗した場合と、ターゲットに接続できない場合 (ユーザー名が間違っているなど) の両方に適用されることに注意してください。 | マッピング パラメーター | 説明 |
---|
| ターゲットデータセットのID | | インポートテンプレートのID (インポート設定定義) | ID attribute | IDを格納するために使用する列 (列のコード) 例: L_ID | Receiver Attribute | Receiverを格納するために使用する必要がある列 (列のコード) 例: L_RECEIVER | Content Attribute | ソースコンテンツ (JSONなど) を保存するために使用する列 (列のコード) 例: L_JSON | Timestamp Attribute | タイムスタンプを格納するために使用する必要がある列 (列のコード) 例: L_TIMESTAMP | Mapping | ソースデータとデータセット列 (属性とインジケータ) のマッピング 例: L_SENSOR_ID= sensorId,M_ACCELER_X=acceler_x,M_ACCELER_Y=acceler_y,M_ACCELER_Z=acceler_z,M_INERT_ACCELER_X=inert_acceler_x | インポート方法 パラメーター | 説明 |
---|
Append | 新しい行がデータセットに追加されます | Update | 受信したデータの値が「更新のために一致する列のコンマ区切りリスト」で設定された列のデータセットのデータと一致する場合、それらはマッピングで設定された値で上書きされます。一致するものが見つからない場合、アクションは実行されません。 |
初期化時に接続が確立されていない場合 (BellaDatiが実行されていないなど)、アクションはデータの送信時に再接続を試みます。
データをBellaDatiに一括送信このアクションにより、データがBellaDatiモジュールに送信されます。このアクションを使用できるようにするには、マッピングを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | マッピング パラメーター | 説明 |
---|
| ターゲットデータセットのID | | インポートテンプレートのID (インポート設定定義) | ID attribute | IDを格納するために使用する列 (列のコード) 例: L_ID | Receiver Attribute | Receiverを格納するために使用する必要がある列 (列のコード) 例: L_RECEIVER | Content Attribute | ソースコンテンツ (JSONなど) を格納するために使用する列 (列のコード) 例: L_JSON | Timestamp Attribute | タイムスタンプを格納するために使用する必要がある列 (列のコード) 例: L_TIMESTAMP | Mapping | ソースデータとデータセット列(属性とインジケータ)のマッピング 例: L_SENSOR_ID=sensorId,M_ACCELER_X=acceler_x,M_ACCELER_Y=acceler_y,M_ACCELER_Z=acceler_z,M_INERT_ACCELER_X=inert_acceler_x | インポート方法 パラメーター | 説明 |
---|
Append | 新しい行がデータセットに追加されます | Update | 受信したデータの値が「更新のために一致する列のコンマ区切りリスト」で設定された列のデータセットのデータと一致する場合、それらはマッピングで設定された値で上書きされます。一致するものが見つからない場合、アクションは実行されません。 |
接続が確立されていない場合、5回試行された後、Senderは一時停止されます。
リモートデータベースに送信このアクションにより、PostgreSQLデータベースにデータを直接挿入できます。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | マッピング パラメーター | 説明 |
---|
| このフィールドには、スキーマとテーブル名がドットで区切られて含まれています 例: nameOfSchema.nameOfTable | ID attribute | IDを格納するために使用する列 (列のコード) 例: L_ID | Receiver Attribute | Receiverを格納するために使用する必要がある列 (列のコード) 例: L_RECEIVER | Content Attribute | ソースコンテンツ (JSONなど) を格納するために使用する列 (列のコード) 例: L_JSON | Timestamp Attribute | タイムスタンプを格納するために使用する必要がある列 (列のコード) 例: L_TIMESTAMP | Now Datetime Column | "NOW()"値が入力される列 (任意) 例: L_NOW | Primary key Column | テーブルに自動インクリメント列が定義されていない場合に必要な、主キーを含む列 例: row_uid | Primary key sequence | 主キーの生成に使用されるシーケンス。主キーが定義されている場合に必要です。 例: nameOfSchema.SEQ_nameOfTable | Mapping | ソースデータとデータセット列(属性とインジケータ)のマッピング 例: L_SENSOR_ID=sensorId,M_ACCELER_X=acceler_x,M_ACCELER_Y=acceler_y,M_ACCELER_Z=acceler_z,M_INERT_ACCELER_X=inert_acceler_x | JDBC Connection string |
例: jdbc:postgresql://localhost:5432/belladati_db | DB Driver | データベースへの接続に使用されるドライバー | DB username | 指定されたスキーマとテーブルへの書き込みアクセス権を持つユーザーのユーザー名 | DB Password | DBユーザー名に設定されているユーザーのパスワード | Number of database workers | データの各バルクはchunks (ヘッダーを持つ、ひとまとまりのデータ) に分割され、それらのchunksはワーカーバーティクルに送信されます。これは、これらのバーティクルの数です。各バーティクルは、データベースとトランザクションへの独自の接続を作成します。 | Rows per transaction | 各バーティクルは、この数の行を挿入します。トランザクションごとのワーカーと行の組み合わせを使用して、パフォーマンスとメモリ消費を最適化できます。ワーカーが多いほど、メモリの消費量が多くなり、パフォーマンスが向上します。 |
これらの情報はすべて、データセットの詳細設定にあります。
ファイルに保存このアクションにより、出力がサーバー上のテキストファイルに保存されます。ファイルへのパスは、installation_dir/data/NameOfSender/NameOfReceiver/ 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | MQTT Publishこのアクションは、データをMQTTブローカーに公開するために使用されます。このアクションを使用できるようにするには、接続パラメーターとメッセージを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | 接続 パラメーター | 説明 |
---|
| MQTTブローカーのIPアドレスのURL | Port | MQTTブローカーが実行されているポート | Transport type | WebsocketのTCP (ws/wss) | Path | Websocketトランスポートタイプでのみ使用できます。 MQTT Websocketブローカーが実行されている相対パスを指定します | Topic | メッセージを公開するトピック | QoS | どのレベルのサービス品質を使用する必要があるか | Message content | メッセージの内容。 ${NameOfField} 形式のタグを使用して、入力値を参照することができます。 例: The pressure is ${pressure} and the temperature is ${temperature}. | Authentication type | どのタイプの認証を使用する必要があるか。利用可能なオプション: - None
- Basic
- Digest
- Client certificate
| Use SSL | SSLを有効にします | Continue on error | このトグルは、データの送信が失敗した場合のsenderの動作に影響を与えます。 無効にすると、未処理のデータはreceiverから削除されず、同じデータに対してアクションが再度トリガーされます。 有効にすると、データはreceiverから削除され、新しいデータが到着するまでアクションはトリガーされません。 このオプションは、データの送信中にアクションが失敗した場合にのみ適用されることに注意してください。様々な理由 (ターゲットに接続できないなど) でアクションが失敗した場合、アクション全体が失敗します。 例: Incorrect port - Continue on error is not applied. | Kafkaパブリッシュこのアクションは、Kafkaコンシューマーにデータを公開するために使用されます。このアクションを使用するためには、接続パラメータとメッセージを指定する必要があります。 全般パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) |
接続Parameter | Description |
---|
Bootstrap servers | Kafka ConsumerのIPアドレスとポートのURL | Path | Websocket Transportタイプでのみ利用可能です。MQTT Websocketブローカーが動作している相対パスを指定します | Topic | メッセージを公開するトピック | Numbers of acknowledgments | Kafkaにデータを書き込むために、プロデューサはもう一つの選択肢として確認応答(acknowledgement)を持っています。つまり、プロデューサは以下のような確認応答を受け取ることで、データ書き込みの確認を得ることができます。 | Message content | メッセージの内容です。入力値を参照するには、${NameOfField}のような形式のタグを使用します。 Example: The pressure is ${pressure} and the temperature is ${temperature}. |
Eメールこのアクションにより、データがEメールで送信されます。このアクションを使用できるようにするには、接続パラメーターとメッセージを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | 接続 パラメーター | 説明 |
---|
| SMTP hostのIPアドレスのURL | Port | SMTP hostが実行されているポート | Use SSL/TLS | SSL/TLSを有効にします | Username | SMTPユーザーのユーザー名 | Password | SMTPユーザーのパスワード | Sender email | Eメールの送信元のアドレスを定義します | Sender caption | 送信者の名前 | Recipients | 受信者のリスト | Subject | メールの件名 | Content Type | Eメールのコンテンツタイプ (text/plain, text/html) | Message content | メッセージの内容。 ${NameOfField} 形式のタグを使用して、入力値を参照することができます。 例: The pressure is ${pressure} and the temperature is ${temperature}. | Continue on error | このトグルは、データの送信が失敗した場合のsenderの動作に影響を与えます。 無効にすると、未処理のデータはreceiverから削除されず、同じデータに対してアクションが再度トリガーされることはありません。 有効にすると、データはreceiverから削除され、新しいデータが到着するまでアクションはトリガーされません。 | HTTP リクエストこのオプションを使用すると、データは標準的な方法 (POST, GET, DELETE, PUT) のいずれかを使用してHTTP経由で送信されます。このオプションは、データを別のサービスまたはアプリケーションに転送する必要がある場合に役立ちます。このアクションを使用できるようにするには、接続パラメーターとメッセージを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | 接続 パラメーター | 説明 |
---|
Method | どのHTTPメソッドを使用する必要があるか | Port | ターゲットエンドポイントのポート 例: 80 | Hostname | ターゲットエンドポイントのホスト名 例: belladatiiotservice.com
| Relative URI | ターゲットエンドポイントの相対URI 例: /postendpoint | HTTP headers | HTTPヘッダーの仕様; 行ごとに1つのヘッダー 例: header1=value1 header2=value2 | HTTP POST content | HTTPボディの仕様。${NameOfField} 形式のタグを使用して、入力値を参照できます。 例: The pressure is ${pressure} and the temperature is ${temperature}. | Send as Form | cUrlの --data-urlencode と同様に、データのURLエンコードを有効にします。 有効にすると、コンテンツの各行は = で分割された1つのエントリになります。 例: From=+123456789
Body=This is the message
To=+987654321 | Authentication type | どのタイプの認証を使用する必要があるか。利用可能なオプション: - None
- Basic
- Digest
- Client certificate
| Use SSL | SSLを有効にします | Continue on error | このトグルは、データの送信が失敗した場合のsenderの動作に影響を与えます。 無効にすると、未処理のデータはreceiverから削除されず、同じデータに対してアクションが再度トリガーされます。 有効にすると、データはreceiverから削除され、新しいデータが到着するまでアクションはトリガーされません。 | TCP/IP Publishこのアクションは、データをTCP/IPエンドポイントに公開するために使用されます。このアクションを使用できるようにするには、接続パラメーターとメッセージを指定する必要があります。 全般 パラメーター | 説明 |
---|
Name | アクションの名前 | Transformation | このアクションで使用する必要がある 変換変換 (任意) | 接続 パラメーター | 説明 |
---|
| TCP/IPエンドポイントのURLまたはIPアドレス | Port | TCP/IPエンドポイントが実行されているポート | Payload | メッセージの内容。ペイロードは、クライアント要求を送信するための標準に従う必要があります 例 1: GET /login HTTP/1.1
Host: localhost:8080
例 2: POST /contact_form.php HTTP/1.1
Host: localhost:8080
Content-Length: 64
Content-Type: application/x-www-form-urlencoded
name=Joe%20User&request=Send%20me%20one%20of%20your%20catalogue
${NameOfField} 形式のタグを使用して、入力値を参照できます。 例: POST /contact_form.php HTTP/1.1
Host: localhost:8080
Content-Length: 64
Content-Type: application/x-www-form-urlencoded
name=Joe%20User&request=Send%20me%20one%20of%20your%20${catalogue}
| アクションルールアクションルールは、様々なタイプのデータ駆動型条件を使用して送信データをフィルタリングするために使用できます。各アクションルールは、フィールド、演算子、値によって定義されます。 アクションルールを適用するには、アクションをこのルールに割り当てる必要があります。複数のルールを追加することが可能であり、各ルールは複数の条件 (フィールド) を持つことができます。 1つのアクションに複数のルールが割り当てられている場合、実行するには、それらの少なくとも1つ (またはルール間の演算子) をパスする必要があります: ルール 1 | ルール 2 | 結果 |
---|
パス | × | 実行 | パス | パス | 実行 (1回のみ) | × | × | 実行されない | 1つのアクションルールに複数の条件 (フィールド) がある場合、値はすべての条件 (AND演算子) に一致する必要があります。 フィールド 1 | フィールド 2 | 結果 |
---|
パス | × | 実行されない | パス | パス | 実行 (1回のみ) | × | × | 実行されない | アクションルールの追加新しいアクションルールを追加するには、ユーザーは[新しいフィルタールール]をクリックする必要があります。ポップアップウィンドウで、ルールの名前を入力してから、このルールに関連付けるアクションを選択する必要があります (CTRLを使用して複数のアクションを選択/選択解除します)。最後に、少なくとも1つの条件を指定する必要があります。各条件は、フィールド、演算子、値で構成されます。 条件の準備ができたら、ユーザーは[追加]をクリックしてルールを保存し、ポップアップウィンドウを閉じる必要があります。
Info |
---|
ドット文字 (".") は、json構造を定義するために使用されます。ドットの後の最後の要素が評価されます。 例: - 要素の構造: ch.A.raw
- 評価される要素: raw
|
最後のステップとして、ユーザーは[適用]をクリックして変更をsenderに保存する必要があります。
アクションルールの編集アクションルールを編集するには、ユーザーは行をクリックする必要があります。
アクションルールの削除アクションルールを削除するには、ユーザーは アイコンをクリックしてアクションを確認する必要があります。
操作を完了するには、ユーザーは[適用]をクリックして変更をsenderに保存する必要があります。
アクションルールオプション次の演算子が使用可能です: - greater than
- lower than
- equals
- not equal to
- greater than or equal to
- lower than or equal to
- contains
- doesn't contain
- not empty
- empty
"not empty" および "empty" 演算子の場合、比較値は使用できません。
|