Hi, I'm Ask INFA!
What would you like to know?
ASK INFAPreview
Please to access Ask INFA.

目次

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. RunAJobユーティリティ
  9. ParamSetCliユーティリティ
  10. REST APIコード
  11. 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ソースとフラットファイルターゲットを使用する
ストリーミング取り込みとレプリケーション
タスクを更新するには、次の例のような要求を送信します。
POST <serverUrl>/sisvc/restapi/v1/UpdateEntity/Documents('<document ID>') Content-Type: application/json Accept: application/json IDS-SESSION-ID: <SessionId> { "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" } ] }