ジョブ管理API
Version 22.0.8483
Version 22.0.8483
ジョブ管理API
ジョブの管理
REST API は、次のジョブ管理アクションをサポートしました。
- すべてのジョブをリスト
- ジョブを作成
- ジョブを編集
- ジョブを削除
- すべての変換をリスト
- 変換を作成
- 変換を編集
- 変換を削除
- ジョブまたは変換を実行
- ジョブでタスクを実行
- 実行中のジョブをキャンセル
- ジョブステータスを取得
- ジョブの履歴を取得
- ジョブからログをダウンロード
- ジョブのすべてのタスクをリスト
- ジョブにタスクを追加
- タスクを更新
- タスクを削除
すべてのジョブをリスト
Sync アプリケーション内のすべてのジョブのリストを返します。
GET http://mydomain.com:8019/api.rsc/jobs(jobname)
クエリパラメータ
名前 | 説明 |
---|---|
JobName | 取得するジョブの名前。 |
ジョブを作成
Sync アプリケーションで実行する新しいジョブを作成します。
POST http://mydomain.com:8019/api.rsc/jobs
ボディパラメータ
名前 | 説明 |
---|---|
JobName | ジョブ名。 |
Source | ソースの接続名。 |
Destination | 同期先の接続名。 |
Scheduled | 特定のスケジューラーに従ってジョブを実行できるようにするには、これをtrue に設定します。 |
ScheduledCron | スケジューラーのcron 文字列。 |
NotifyWindowsEvent | エラーメッセージをWindows アプリケーション イベントログに書き込むには、これをtrue に設定します。 |
SendEmailNotification | ジョブの完了後にE メール通知を送信するには、これをtrue に設定します。 |
NotifyEmailTo | 通知E メールの送信先アドレス。 |
NotifyEmailSubject | 通知E メールの件名。 |
EmailErrorOnly | エラー時にのみメールを送信します。 |
Verbosity | ジョブのログのverbosity レベル。 |
TableNamePrefix | レプリケートされたすべてのテーブルのプレフィックス。 |
UseGmtDateTime | 現地時間ではなくGMT タイムゾーンで時刻を同期するには、これをtrue に設定します。 |
TruncateTableData | 各更新の前にすべての行を削除するには、これをtrue に設定します。 |
DropTable | 各更新の前にテーブルを削除するには、これをtrue に設定します。 |
AutoTruncateStrings | カラムサイズに対して大きすぎる文字列を自動的に切り捨てるには、これをtrue に設定します。 |
ContinueOnError | 前のテーブルがエラーをスローしたときに次のテーブルに進むには、これをtrue に設定します。 |
AlterSchema | これをtrue に設定すると、同期元テーブルと同期先テーブルのメタデータに不一致があった場合は、カラムを追加してデータ型を変更します。 |
ReplicateInterval | ReplicateIntervalUnit とペアで設定すると、ReplicateInterval はレプリケート時にデータを分割するタイムフレームを制御します。 |
ReplicateIntervalUnit | ReplicateInterval とペアで設定すると、ReplicateIntervalUnit はレプリケート時にデータを分割するタイムフレームを制御します。値は、minutes、hours、days、weeks、months、years です。 |
ReplicateStartDate | このオプションは、データの複製を開始する最小の日付(yyyy-MM-dd)を設定します。 |
BatchSize | バッチのサイズを設定します。 |
CommandTimeout | 同期先の接続のタイムアウトを制御します。 |
SkipDeleted | 同期元から削除されたレコードの取得をスキップするかどうか。 |
OtherCacheOptions | 含める追加オプションのカンマ区切りのリスト。 |
CacheSchema | 同期先データベースの特定のスキーマを割り当てます。 |
PreJob | Pre-Job イベントのコード。 |
PostJob | Post-Job イベントのコード。 |
Query# | ジョブに含めるSQL ステートメントの配列。 |
{
"JobName": "MyNewJob",
"Source": "SourceConnection",
"Destination": "DestinationConnection",
"Query#1":"REPLICATE [Accounts]",
"Query#2": "REPLICATE [Invoices]"
}
ジョブを編集
既存のジョブを編集します。実行中のジョブを編集することはできません。
PUT http://mydomain.com:8019/api.rsc/jobs(jobname)
クエリパラメータ
名前 | 説明 |
---|---|
JobName(必須) | 編集するジョブの名前。 |
ボディパラメータ
名前 | 説明 |
---|---|
Scheduled | 特定のスケジューラーに従ってジョブを実行できるようにするには、これをtrue に設定します。 |
ScheduledCron | スケジューラーのcron 文字列。 |
NotifyWindowsEvent | エラーメッセージをWindows アプリケーション イベントログに書き込むには、これをtrue に設定します。 |
SendEmailNotification | ジョブの完了後にE メール通知を送信するには、これをtrue に設定します。 |
NotifyEmailTo | 通知E メールの送信先アドレス。 |
NotifyEmailSubject | 通知E メールの件名。 |
EmailErrorOnly | エラー時にのみメールを送信します。 |
Verbosity | ジョブのログのverbosity レベル。値は1,2,3,5 です。 |
TableNamePrefix | レプリケートされたすべてのテーブルのプレフィックス。 |
UseGmtDateTime | 現地時間ではなくGMT タイムゾーンで時刻を同期するには、これをtrue に設定します。 |
TruncateTableData | 各更新の前にすべての行を削除するには、これをtrue に設定します。 |
DropTable | 各更新の前にテーブルを削除するには、これをtrue に設定します。 |
AutoTruncateStrings | カラムサイズに対して大きすぎる文字列を自動的に切り捨てるには、これをtrue に設定します。 |
ContinueOnError | 前のテーブルがエラーをスローしたときに次のテーブルに進むには、これをtrue に設定します。 |
AlterSchema | これをtrue に設定すると、同期元テーブルと同期先テーブルのメタデータに不一致があった場合は、カラムを追加してデータ型を変更します。 |
ReplicateInterval | ReplicateIntervalUnit とペアで設定すると、ReplicateInterval はレプリケート時にデータを分割するタイムフレームを制御します。 |
ReplicateIntervalUnit | ReplicateInterval とペアで設定すると、ReplicateIntervalUnit はレプリケート時にデータを分割するタイムフレームを制御します。値は、minutes、hours、days、weeks、months、years です。 |
ReplicateStartDate | このオプションは、データの複製を開始する最小の日付(yyyy-MM-dd)を設定します。 |
BatchSize | バッチのサイズを設定します。 |
CommandTimeout | 同期先の接続のタイムアウトを制御します。 |
SkipDeleted | 同期元から削除されたレコードの取得をスキップするかどうか。 |
OtherCacheOptions | 含める追加オプションのカンマ区切りのリスト。 |
CacheSchema | 同期先データベースの特定のスキーマを割り当てます。 |
PreJob | Pre-Job イベントのコード。 |
PostJob | Post-Job イベントのコード。 |
{
"Scheduled": "true",
"ScheduledCron": "0-30/5 * * * *"
}
ジョブを削除
Sync アプリケーションからジョブを削除します。実行中のジョブを削除することはできません。
DELETE http://mydomain.com:8019/api.rsc/jobs(jobname)
クエリパラメータ
名前 | 説明 |
---|---|
JobName | 削除するジョブの名前。 |
すべての変換をリスト
Sync アプリケーション内のすべての変換のリストを返します。
GET http://mydomain.com:8019/api.rsc/transformations(transformationname)
クエリパラメータ
名前 | 説明 |
---|---|
TransformationName | 取得する変換の名前。 |
変換を作成
Sync アプリケーションで実行する新しいジョブを作成します。
POST http://mydomain.com:8019/api.rsc/transformations
ボディパラメータ
名前 | 説明 |
---|---|
TransformationName | 変換の名前。 |
Connection | 同期先の接続名。 |
TransformationTriggerMode | スケジュールに従って変換を実行するか、ジョブ後に変換を実行するか。デフォルトはNone です。値はNone、Scheduled、AfterJob |
TriggerAfterJob | 変換がその後で実行されるように指定したジョブ。 |
TriggerTasks | タスクID のカンマ区切りのリスト。 |
ScheduledCron | スケジューラーのcron 文字列。 |
SendEmailNotification | 変換の完了後にE メール通知を送信するには、これをtrue に設定します。 |
NotifyEmailTo | 通知E メールの送信先アドレス。 |
NotifyEmailSubject | 通知E メールの件名。 |
EmailErrorOnly | エラー時にのみメールを送信します。 |
Verbosity | 変換のログの詳細レベル。 |
Query# | 変換に含めるSQL ステートメントの配列。 |
{
"TransformationName": "MyNewTransformation",
"Connection": "DestinationConnection",
"Query#1":"CREATE OR REPLACE TABLE dbo.Accounts_Deduplicated as (SELECT *, row_number() over (partition by id order by modified desc) as duplicate_rank FROM dbo.Accounts);",
"Query#2": "DELETE FROM dbo.Accounts_Deduplicated WHERE duplicate_rank > 1;"
}
変換を編集
既存の変換を編集します。実行中の変換を編集することはできません。
PUT http://mydomain.com:8019/api.rsc/transformations(transformationname)
クエリパラメータ
名前 | 説明 |
---|---|
TransformationName(必須) | 編集する変換の名前。 |
ボディパラメータ
名前 | 説明 |
---|---|
TransformationTriggerMode | スケジュールに従って変換を実行するか、ジョブ後に変換を実行するか。デフォルトはNone です。値はNone、Scheduled、AfterJob |
TriggerAfterJob | 変換がその後で実行されるように指定したジョブ。 |
TriggerTasks | タスクID のカンマ区切りのリスト。 |
ScheduledCron | スケジューラーのcron 文字列。 |
SendEmailNotification | 変換の完了後にE メール通知を送信するには、これをtrue に設定します。 |
NotifyEmailTo | 通知E メールの送信先アドレス。 |
NotifyEmailSubject | 通知E メールの件名。 |
EmailErrorOnly | エラー時にのみメールを送信します。 |
Verbosity | 変換のログの詳細レベル。 |
{
"TransformationTriggerMode": "Scheduled",
"ScheduledCron": "0-30/5 * * * *"
}
変換を削除
Sync アプリケーションから変換を削除します。実行中の変換を削除することはできません。
DELETE http://mydomain.com:8019/api.rsc/transformations(transformationname)
クエリパラメータ
名前 | 説明 |
---|---|
TransformationName(必須) | 削除する変換の名前。 |
ジョブを実行
指定されたジョブまたは変換の実行を開始します。
POST http://mydomain.com:8019/api.rsc/executeJob
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | 実行するジョブの名前。 |
WaitForResults | ジョブが終了するまで結果を返すことを待つかどうか。デフォルトはtrue です。 |
Timeout | 前のジョブ実行が完了するまでの待ち時間(秒単位)。 |
{
"JobName": "MyJob",
"WaitForResults" : true,
"Timeout": 30
}
ジョブでクエリを実行
ジョブ内で特定のクエリの実行を開始します。クエリはすでにジョブの一部である必要があります。
POST http://mydomain.com:8019/api.rsc/executeQuery
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | 実行するジョブの名前。 |
Query#(必須) | 実行するQuery ステートメントの配列。Query#1、Query#2 などの構文で複数のクエリを指定。 |
WaitForResults | ジョブが終了するまで結果を返すことを待つかどうか。デフォルトはtrue です。 |
{
"JobName": "MyJob",
"Query#1": "REPLICATE [Accounts]",
"Query#2": "REPLICATE [Contacts]"
}
ジョブをキャンセル
実行中のジョブをキャンセルします。ジョブはすでに実行中である必要があります。
POST http://mydomain.com:8019/api.rsc/cancelJob
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | キャンセルするジョブの名前。 |
{
"JobName": "MyJob"
}
ジョブステータスを取得
ジョブのステータスを取得します。
POST http://mydomain.com:8019/api.rsc/getJobStatus
ボディパラメータ
名前 | 説明 |
---|---|
JobName | ステータスを取得するジョブの名前。指定した場合、応答には、ジョブ内の各クエリの詳細が含まれます。 |
{
"JobName":"MyJob"
}
ジョブの履歴を取得
ジョブの以前の実行の履歴を取得します。
GET http://mydomain.com:8019/api.rsc/history
クエリパラメータ
名前 | 説明 |
---|---|
JobName | 履歴を取得するジョブの名前。 |
ジョブのログをダウンロード
ジョブのログファイルのBase64 エンコードされたコンテンツをダウンロードします。
POST http://mydomain.com:8019/api.rsc/getLogs
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | ログを取得するジョブの名前。 |
Days(必須) | 含めるログファイルの日数。 |
タスクをリスト
ジョブや変換に関連するタスクのリストを取得します。
GET http://mydomain.com:8019/api.rsc/tasks(jobname)
クエリパラメータ
名前 | 説明 |
---|---|
JobName(必須) | ジョブの名前。 |
タスクを追加
既存のジョブまたは変換にタスクを追加します。Query またはTable のいずれかが必須です。
POST http://mydomain.com:8019/api.rsc/tasks
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | ジョブの名前。 |
Query | タスクとして設定するクエリ。 |
Table | レプリケートするソーステーブル。Sync はこのインプットからReplicate Query を作成します。 |
タスクを編集
既存のジョブまたは変換のタスクを更新します。
PUT http://mydomain.com:8019/api.rsc/tasks
ボディパラメータ
名前 | 説明 |
---|---|
JobName(必須) | ジョブの名前。 |
TaskId(必須) | 更新するタスク。 |
Query | タスクとして設定するクエリ。 |
Table | レプリケートするソーステーブル。Sync はこのインプットからReplicate Query を作成します。 |
タスクを削除
既存のジョブまたは変換からタスクを削除します。
DELETE http://mydomain.com:8019/api.rsc/tasks
クエリパラメータ
名前 | 説明 |
---|---|
JobName(必須) | ジョブの名前。 |
TaskId(必須) | 削除するタスク。 |