データフロータスクを作成します。
操作説明
-
CPFS の使用上の注意
データフローは CPFS 2.2.0 以降でのみサポートされています。バージョン情報は、コンソールのファイルシステム詳細ページで確認できます。
データフロータスクは非同期で実行されます。 DescribeDataFlowTasks を呼び出して、タスク実行ステータスをクエリできます。タスクに必要な時間は、インポートまたはエクスポートするデータ量によって異なります。large なデータが関わる場合は、データを複数のタスクにコスト配分してください。
データフロータスクは、Running 状態のデータフローに対してのみ作成できます。
データフロータスクを手動で実行すると、データフローの自動データ更新タスクが中断され、待機状態になります。
エクスポートタスクを作成する際は、CPFS からエクスポートするファイルの絶対パスの合計長さが 1,023 文字を超えないことを確認してください。
-
Lingjun 向け CPFS の使用上の注意
データフローは Lingjun 向け CPFS 2.4.0 以降でのみサポートされています。バージョン情報は、コンソールのファイルシステム詳細ページで確認できます。
データフロータスクは非同期で実行されます。 DescribeDataFlowTasks を呼び出して、タスク実行ステータスをクエリできます。タスクに必要な時間は、インポートまたはエクスポートするデータ量によって異なります。large なデータが関わる場合は、データを複数のタスクにコスト配分してください。
データフロータスクは、Running 状態のデータフローに対してのみ作成できます。
エクスポートタスクを作成する際は、Lingjun 向け CPFS からエクスポートするファイルの絶対パスの合計長さが 1,023 文字を超えないことを確認してください。
Lingjun 向け CPFS は、バッチタスクとストリームタスクの 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 文字以下である必要があります。詳細については、「べき等性を確保する方法」を参照してください。 説明
このパラメーターを指定しない場合、システムは API リクエストの RequestId を ClientToken として自動的に使用します。RequestId は API 呼び出しごとに異なる場合があります。 |
123e4567-e89b-12d3-a456-42665544**** |
| DryRun |
boolean |
任意 |
ドライランを実行するかどうかを指定します。 ドライランでは、パラメーターの有効性と必要なリソースが利用可能かどうかがチェックされます。ドライランではインスタンスの作成や料金の発生は行われません。 有効な値:
|
false。 |
| TaskAction |
string |
任意 |
データフローノードタイプ。 有効な値:
説明
Lingjun 向け CPFS は、Import、Export、StreamImport、および StreamExport のみをサポートしています。StreamImport と StreamExport は、Lingjun 向け CPFS 2.6.0 以降でのみサポートされています。 列挙値:
|
Import。 |
| DataType |
string |
任意 |
データフロータスクが操作するデータの型。 有効な値:
説明
TaskAction が Evict にセットされている場合、DataType パラメーターは必須です。 列挙値:
|
Metadata。 |
| Directory |
string |
任意 |
データのソースディレクトリ。 使用制限:
説明
StreamImport と StreamExport は、Lingjun 向け CPFS 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 は、Lingjun 向け CPFS 2.6.0 以降でのみサポートされています。 |
/path_in_cpfs/ |
| CreateDirIfNotExist |
boolean |
任意 |
フォルダが存在しない場合に自動作成を有効にするかどうかを指定します。 有効な値:
説明
|
false。 |
| ConflictPolicy |
string |
任意 |
同名ファイルの競合ポリシー。 有効な値:
説明
ファイルシステムタイプが Lingjun 向け CPFS の場合、このパラメーターは必須です。 |
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 が存在しません。 |
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。