目次

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リファレンス

Amazon Kinesis Streamsをソースおよびターゲットとするタスクの接続構成

Amazon Kinesis Streamsをソースおよびターゲットとするタスクの接続構成

タスクのソース接続とターゲット接続がAmazon Kinesis Streamsの場合、ソース接続とターゲット接続の構成配列に次のフィールドおよびキーと値のペアを含めることができます。
キー
タイプ
必須
説明
appendGUID
Boolean
Amazon DynamoDBテーブル名にサフィックスとしてGUIDを追加するかどうかを指定します。
次のいずれかの値を入力します。
  • true
  • false
DynamoDB
String
Kinesisソースデータのチェックポイントの詳細を保存するAmazon DynamoDBテーブル名。
128文字までの文字列を入力できます。
Stream
String
データの読み取り元のKinesis Streamの名前。
128文字までの文字列を入力します。
ソースノードに表示されます。
Stream Name/Expression
String
データの書き込み先のKinesis Stream名または正規表現。
128文字までの文字列を入力します。
ターゲットノードに表示されます。

POST要求の例

Amazon Kinesis StreamsソースとAmazon Kinesis Streamsターゲットを使用する
ストリーミング統合
タスクを更新するには、次の例のような要求を送信できます。
{ "name": "kinesis to kinesis", "description": "kinesis to kinesis", "runtimeId": "01000025000000000003", "locationId": "5sJ0JDyJyWLlrosS5qJjsQ", "currentVersion": "2", "messageFormat": "binary", "nodes": [ { "name": "kinesis to kinesis_source", "type": "source", "connectionId": "012MGS0B00000000000F", "transformationType": "", "config": [ { "key": "appendGUID", "value": true }, { "key": "dynamoDB", "value": "table" }, { "key": "Stream", "value": "test" } ] }, { "name": "kinesis to kinesis_target", "type": "target", "connectionId": "012MGS0B00000000000F", "transformationType": "", "config": [ { "key": "Stream Name/Expression", "value": "trgt" } ] } ], "edges": [ { "from": "kinesis to kinesis_source", "to": "kinesis to kinesis_target" } ] }