データフロータスクを作成します。
操作説明
-
CPFS に関する注意事項
データフローは CPFS 2.2.0 以降でのみサポートされています。コンソールのファイルシステム詳細ページでバージョン情報をビューできます。
データフロータスクは非同期で実行されます。タスク実行ステータスをクエリするには、 DescribeDataFlowTasks を呼び出します。タスクに必須の時間は、インポートまたはエクスポートするデータ量によって異なります。large なデータ量の場合は、データを複数のタスクにコスト配分してください。
データフロータスクは、実行中 (Running) 状態のデータフローに対してのみ作成できます。
データフロータスクを手動で実行すると、データフローの自動データ更新タスクが中断され、待機状態になります。
エクスポートタスクを作成する際は、CPFS からエクスポートするファイルの絶対パスの合計文字数が 1,023 文字を超えないようにしてください。
-
CPFS for Lingjun に関する注意事項
データフローは CPFS for Lingjun 2.4.0 以降でのみサポートされています。コンソールのファイルシステム詳細ページでバージョン情報をビューできます。
データフロータスクは非同期で実行されます。タスク実行ステータスをクエリするには、 DescribeDataFlowTasks を呼び出します。タスクに必須の時間は、インポートまたはエクスポートするデータ量によって異なります。large なデータ量の場合は、データを複数のタスクにコスト配分してください。
データフロータスクは、実行中 (Running) 状態のデータフローに対してのみ作成できます。
エクスポートタスクを作成する際は、CPFS for Lingjun からエクスポートするファイルの絶対パスの合計文字数が 1,023 文字を超えないようにしてください。
CPFS for Lingjun は、バッチタスクとストリームタスクの 2 種類のタスクタイプをサポートしています。詳細については、「タスクタイプの概要」を参照してください。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
nas:CreateDataFlowTask |
create |
*DataFlow。
|
なし | なし |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| FileSystemId |
string |
必須 |
ファイルシステム ID。
|
cpfs-099394bd928c**** |
| DataFlowId |
string |
必須 |
データフロー ID。 |
df-194433a5be31**** |
| SrcTaskId |
string |
任意 |
SrcTaskId を指定する場合は、データフロータスク ID を入力します。システムは、指定されたデータフロータスクから TaskAction、DataType、および EntryList パラメーター情報をコピーします。これらのパラメーターを個別に指定する必要はありません。 説明
データフローのストリームタスクはサポートされていません。 |
task-29ee8e890f45**** |
| ClientToken |
string |
任意 |
リクエストのべき等性を確保するために使用されるクライアントトークン。クライアントを使用してトークンを生成できますが、異なるリクエスト間でトークンが一意であることを確認してください。 トークンには ASCII 文字のみを使用でき、長さは 64 文字を超えることはできません。詳細については、「べき等性を確保する方法」を参照してください。 説明
このパラメーターを指定しない場合、システムは RequestId の値を ClientToken の値として自動的に使用します。RequestId の値は、API 呼び出しごとに異なる場合があります。 |
123e4567-e89b-12d3-a456-42665544**** |
| DryRun |
boolean |
任意 |
ドライランを実行するかどうかを指定します。 ドライランでは、実際にインスタンスを作成したり、料金が発生したりすることなく、パラメーターの有効性とリソースの可用性がチェックされます。 有効な値:
|
false |
| TaskAction |
string |
任意 |
データフローノードタイプ。 有効な値:
説明
CPFS for Lingjun は Import、Export、StreamImport、StreamExport のみをサポートしています。StreamImport と StreamExport は CPFS for Lingjun 2.6.0 以降でのみサポートされています。 列挙値:
|
Import |
| DataType |
string |
任意 |
データフロータスクが操作するデータのタイプ。 有効な値:
説明
TaskAction が Evict にセットされている場合、DataType パラメーターは必須です。 列挙値:
|
Metadata |
| Directory |
string |
任意 |
データのソースディレクトリ。 使用制限:
説明
StreamImport と StreamExport は CPFS for Lingjun 2.6.0 以降でのみサポートされています。 Directory、EntryList、および TransferFileListPath は相互排他パラメーターです。指定できるのはそのうちの 1 つだけです。 |
/path_in_cpfs/ |
| EntryList |
string |
任意 |
データフロータスクが実行されるファイルのリスト。 使用制限:
説明
Directory、EntryList、および TransferFileListPath は相互排他パラメーターです。指定できるのはそのうちの 1 つだけです。 |
["/path_in_cpfs/file1", "/path_in_cpfs/file2"] |
| TransferFileListPath |
string |
任意 |
OSS ディレクトリ。OSS ディレクトリ内の CSV ファイルの内容に基づいてデータが同期されます。使用制限:
説明
|
/test_oss_path/ |
| Includes |
string |
任意 |
指定されたディレクトリ配下のディレクトリをフィルタリングし、含まれるフォルダの内容を転送します。 説明
|
["/test/","/test1/"] |
| DstDirectory |
string |
任意 |
データフロータスクがマッピングされるターゲットディレクトリ。 使用制限:
説明
StreamImport と StreamExport は CPFS for Lingjun 2.6.0 以降でのみサポートされています。 |
/path_in_cpfs/ |
| CreateDirIfNotExist |
boolean |
任意 |
フォルダが存在しない場合にフォルダの自動作成を有効にするかどうかを指定します。 有効な値:
説明
|
false |
| ConflictPolicy |
string |
任意 |
同名ファイルの競合ポリシー。 有効な値:
説明
ファイルシステムタイプが CPFS for Lingjun の場合、このパラメーターは必須です。 列挙値:
|
SKIP_THE_FILE |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
object |
|||
| RequestId |
string |
リクエスト ID。 |
2D69A58F-345C-4FDE-88E4-BF518948**** |
| TaskId |
string |
データフロータスク ID。 |
task-38aa8e890f45**** |
例
成功レスポンス
JSONJSON
{
"RequestId": "2D69A58F-345C-4FDE-88E4-BF518948****",
"TaskId": "task-38aa8e890f45****"
}
エラーコード
|
HTTP ステータスコード |
エラーコード |
エラーメッセージ |
説明 |
|---|---|---|---|
| 400 | IllegalCharacters | The parameter contains illegal characters. | 無効なパラメーターです。有効なパラメーターを指定してください。 |
| 400 | MissingFileSystemId | FileSystemId is mandatory for this action. | FileSystemId パラメーターが指定されていません。 |
| 400 | MissingDataFlowId | DataFlowId is mandatory for this action. | DataFlowId パラメーターが指定されていません。 |
| 400 | InvalidFilesystemVersion.NotSupport | This Api does not support this fileSystem version. | 現在の操作はこのファイルシステムバージョンをサポートしていません。 |
| 403 | OperationDenied.InvalidState | The operation is not permitted when the status is processing. | ステータスの処理中は、この操作は許可されていません。 |
| 403 | OperationDenied.DependencyViolation | The operation is denied due to dependancy violation. | この操作の条件が満たされていません。 |
| 403 | OperationDenied.DataFlowNotSupported | The operation is not supported. | このファイルシステムはデータフローをサポートしていません。 |
| 404 | InvalidParameter.InvalidFormat | The EntryList format is invalid. | 指定された EntryList のフォーマットが要件を満たしていません。 |
| 404 | InvalidParameter.SizeTooLarge | The specified EntryList size exceeds 64 KB. | 指定された EntryList のサイズが 64 KB を超えています。 |
| 404 | InvalidDataFlow.NotFound | The specified data flow does not exist. | 指定されたデータフローが存在しません。 |
| 404 | InvalidTaskAction.NotSupported | The task action is not supported. | 指定されたタスクタイプはサポートされていません。 |
| 404 | InvalidTaskAction.PermissionDenied | The task action is not allowed. | 指定されたタスクタイプは許可されていません (システムの複製など)。 |
| 404 | InvalidSrcTaskId.NotFound | The SrcTaskId is not found. | 指定された SrcTaskId が存在しません。 |
| 404 | InvalidDataType.NotSupported | The data type is not supported. | 指定されたデータの型はサポートされていません。 |
| 404 | InvalidSrcTaskId.TaskIdInvalid | Source task ID is invalid. | コピー対象として指定されたタスク ID が無効です。 |
| 404 | InvalidSrcTaskId.TaskIdNotFound | Source task ID is not found. | コピー対象として指定されたタスク ID が存在しません。 |
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。