目次

Search

  1. はじめに
  2. Informatica Intelligent Cloud Services REST API
  3. プラットフォームREST APIバージョン2リソース
  4. プラットフォームREST APIバージョン3リソース
  5. データ統合 REST API
  6. 一括取り込みファイルREST API
  7. 一括取り込みストリーミングREST API
  8. Model Serve REST API
  9. RunAJobユーティリティ
  10. ParamSetCliユーティリティ
  11. REST APIコード
  12. REST APIリソースクイックリファレンス

REST APIリファレンス

REST APIリファレンス

MQTTをソースとするタスクの接続構成

MQTTをソースとするタスクの接続構成

タスクソースのソース接続がMQTTの場合、ソース接続の構成配列に次のフィールドおよびキーと値のペアを含めることができます。
キー
タイプ
必須
説明
ClientID
String
-
MQTTソースとMQTTブローカ間の接続を識別する一意の識別子。クライアントIDは、MQTTソースがメッセージの処理中にメッセージを格納するために使用するファイルベースの永続ストアです。
255文字までの文字列を入力できます。
MaxQueueSize
Integer
-
プロセッサがメモリに保存できるメッセージの最大数。
1から2147483647までの数値を入力できます。
Topic
String
MQTTトピックの名前。

POST要求の例

MQTTソースとフラットファイルターゲットを使用する
ストリーミング統合
タスクを更新するには、次の例のような要求を送信できます。
{ "name": "mqtt to flatfile", "description": "mqtt to flatfile", "runtimeId": "01000025000000000003", "locationId": "5sJ0JDyJyWLlrosS5qJjsQ", "currentVersion": "2", "messageFormat": "binary", "nodes": [ { "name": "mqtt to flatfile_source", "type": "source", "connectionId": "012MGS0B00000000001O", "transformationType": "", "config": [ { "key": "ClientID", "value": "test" }, { "key": "MaxQueueSize", "value": 1024 }, { "key": "Topic", "value": "test" } ] }, { "name": "mqtt to flatfile_target", "type": "target", "connectionId": "012MGS0B00000000002N", "transformationType": "", "config": [ { "key": "interimDirectory", "value": "/home/agent/test" }, { "key": "rolloverSize", "value": 1024 }, { "key": "rolloverEvents", "value": 100 }, { "key": "rolloverTime", "value": 300000 }, { "key": "File Name", "value": "test" } ] } ], "edges": [ { "from": "mqtt to flatfile_source", "to": "mqtt to flatfile_target" } ] }