データフロータスクを作成します。
操作説明
-
CPFS 使用上の注意
データフローは、CPFS 2.2.0 以降でサポートされています。バージョン情報は、コンソールのファイルシステム詳細ページで確認できます。
データフロータスクは非同期に実行されます。タスクのステータスは、DescribeDataFlowTasks オペレーションを呼び出すことでクエリできます。タスクの実行時間はデータ量に依存します。大規模なデータセットの場合は、ワークロードを複数のタスクに分割してください。
データフロータスクは、実行中の状態にあるデータフローでのみ作成できます。
データフロータスクを手動で実行すると、対応する自動データ更新タスクは一時停止します。
エクスポートタスクを作成するときは、CPFS からエクスポートする各ファイルの絶対パスが 1,023 文字を超えないようにしてください。
-
CPFS AI-Computing Edition 使用上の注意
データフローは、CPFS AI-Computing Edition 2.4.0 以降でサポートされています。バージョン情報は、コンソールのファイルシステム詳細ページで確認できます。
データフロータスクは非同期に実行されます。タスクのステータスは、DescribeDataFlowTasks オペレーションを呼び出すことでクエリできます。タスクの実行時間はデータ量に依存します。大規模なデータセットの場合は、ワークロードを複数のタスクに分割してください。
データフロータスクは、実行中の状態にあるデータフローでのみ作成できます。
エクスポートタスクを作成するときは、CPFS AI-Computing Edition からエクスポートする各ファイルの絶対パスが 1,023 文字を超えないようにしてください。
CPFS AI-Computing Edition では、バッチタスクとストリーミングタスクの 2 種類のタスクをサポートしています。詳細については、「タスクの種類」をご参照ください。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
nas:CreateDataFlowTask |
create |
*DataFlow
|
なし | なし |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| FileSystemId |
string |
必須 |
ファイルシステムの ID。
|
cpfs-099394bd928c**** |
| DataFlowId |
string |
必須 |
データフローの ID。 |
df-194433a5be31**** |
| SrcTaskId |
string |
任意 |
説明
データフローストリーミングタスクはサポートされていません。 |
task-29ee8e890f45**** |
| TaskAction |
string |
任意 |
データフロータスクのタイプ。 有効な値:
説明
CPFS AI-Computing Edition では、 |
Import |
| DataType |
string |
任意 |
データフロータスクが扱うデータタイプ。 有効な値:
|
Metadata |
| Directory |
string |
任意 |
データのソースディレクトリ。 制限:
説明
|
/path_in_cpfs/ |
| EntryList |
string |
任意 |
データフロータスクが実行するファイルのリスト。 制限:
|
["/path_in_cpfs/file1", "/path_in_cpfs/file2"] |
| DryRun |
boolean |
任意 |
この作成リクエストに対してドライランを実行するかどうかを指定します。 ドライランは、インスタンスを作成したり料金を発生させたりすることなく、パラメーターの妥当性とインベントリをチェックします。 有効な値:
|
false |
| ClientToken |
string |
任意 |
リクエストのべき等性を保証するクライアント生成トークン。トークンは異なるリクエスト間で一意である必要があります。
説明
このパラメーターを指定しない場合、システムは自動的に API リクエストの |
123e4567-e89b-12d3-a456-42665544**** |
| ConflictPolicy |
string |
任意 |
同じ名前のファイルに対するコンフリクトポリシー。 有効な値:
説明
ファイルシステムが CPFS AI-Computing Edition インスタンスの場合、このパラメーターは必須です。 |
SKIP_THE_FILE |
| DstDirectory |
string |
任意 |
データフロータスクマッピングの宛先ディレクトリ。 制限:
説明
|
/path_in_cpfs/ |
| CreateDirIfNotExist |
boolean |
任意 |
ディレクトリが存在しない場合に自動的に作成するかどうかを指定します。 有効な値:
説明
|
false |
| Includes |
string |
任意 |
説明
|
["/test/","/test1/"] |
| TransferFileListPath |
string |
任意 |
OSS ディレクトリを指定します。データはこのディレクトリ内の CSV ファイルの内容に基づいて同期されます。このパスには以下の制限があります。
説明
|
/test_oss_path/ |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
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. | |
| 400 | MissingDataFlowId | DataFlowId is mandatory for this action. | |
| 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. | |
| 404 | InvalidParameter.SizeTooLarge | The specified EntryList size exceeds 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. | |
| 404 | InvalidDataType.NotSupported | The data type is not supported. | |
| 404 | InvalidSrcTaskId.TaskIdInvalid | Source task ID is invalid. | |
| 404 | InvalidSrcTaskId.TaskIdNotFound | Source task ID is not found. |
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。