ストリーミング取り込みとレプリケーション
使用例
ストリーミング取り込みとレプリケーションソース
Amazon Kinesis Streamsソース
AMQPソース
Azure Event Hubs Kafkaソース
Business 360 Eventsソース
フラットファイルソース
Google PubSubソース
JMSソース
Kafkaソース
MQTTソース
OPC UAソース
REST V2ソース
ストリーミング取り込みとレプリケーションターゲット
Amazon Kinesis Data Firehoseターゲット
Amazon Kinesis Streamsターゲット
Amazon S3ターゲット
Databricksターゲット
フラットファイルターゲット
Google BigQuery V2ターゲット
Google Cloud Storage V2ターゲット
Google PubSubターゲット
JDBC V2ターゲット
Kafkaターゲット
Microsoft Azure Data Lake Storage Gen2ターゲット
Microsoft Azure Event Hubsターゲット
ストリーミング取り込みとレプリケーションのトランスフォーメーション
データ形式
Combinerトランスフォーメーション
フィルタトランスフォーメーション
形式変換トランスフォーメーション
Javaトランスフォーメーション
Joltトランスフォーメーション
Pythonトランスフォーメーション
Splitterトランスフォーメーション
ストリーミング取り込みとレプリケーションタスクの設定
始める前に
基本的なタスク情報の定義
ソースの設定
ターゲットの設定
トランスフォーメーションの設定
ランタイムオプションの設定
ストリーミング取り込みとレプリケーションタスクのデプロイ
ストリーミング取り込みとレプリケーションジョブのデプロイ解除
ストリーミング取り込みとレプリケーションジョブの停止と再開
ストリーミング取り込みとレプリケーションの動作に関するよくある質問
ストリーミング取り込みとレプリケーションREST API
ストリーミング取り込みとレプリケーションタスクのデプロイ、デプロイ解除、開始、および停止
ストリーミング取り込みとレプリケーションタスクのデプロイ
ストリーミング取り込みとレプリケーションタスクのデプロイ解除
ストリーミング取り込みとレプリケーションタスクの開始
ストリーミング取り込みとレプリケーションタスクの停止
ストリーミング取り込みとレプリケーションタスクのコピー
ストリーミング取り込みとレプリケーションタスクの更新
POST要求
POST応答
ストリーミング取り込みとレプリケーションジョブに関する詳細の取得
ストリーミング取り込みとレプリケーションジョブのリストの取得
ジョブステータス
ジョブの統計
ジョブ履歴
ストリーミング取り込みとレプリケーション
ジョブ履歴
SI_TASKS_PAGE_LIST
STREAMING_INGESTION_TASK
SI_DEFINITION
SI_SOURCE
SI_TARGET
SI_TRANSFORMATION
SI_NEW_TRANSFORMATION
SI_RUNTIMEOPTIONS