CreateDataFlowTask - Cloud Parallel File Storage - Centre de documentation Alibaba Cloud

Crée une tâche de flux de données.

Description de l'opération

Remarques sur CPFS
- Seul CPFS 2.2.0 et les versions ultérieures prennent en charge le flux de données. Vous pouvez consulter les informations de version sur la page de détails du système de fichiers dans la console.
- Les tâches de flux de données sont exécutées de manière asynchrone. Vous pouvez appeler DescribeDataFlowTasks pour interroger l'état d'exécution de la tâche. Le temps nécessaire pour une tâche dépend de la quantité de données à importer ou à exporter. Pour de grandes quantités de données, divisez les données en plusieurs tâches.
- Vous ne pouvez créer une tâche de flux de données que sur un flux de données à l'état Running.
- Lorsque vous exécutez manuellement une tâche de flux de données, la tâche de mise à jour automatique des données du flux de données est interrompue et mise en attente.
- Lorsque vous créez une tâche d'exportation, assurez-vous que la longueur totale du chemin absolu du fichier à exporter depuis CPFS ne dépasse pas 1 023 caractères.
Remarques sur CPFS for Lingjun
- Seul CPFS for Lingjun 2.4.0 et les versions ultérieures prennent en charge le flux de données. Vous pouvez consulter les informations de version sur la page de détails du système de fichiers dans la console.
- Les tâches de flux de données sont exécutées de manière asynchrone. Vous pouvez appeler DescribeDataFlowTasks pour interroger l'état d'exécution de la tâche. Le temps nécessaire pour une tâche dépend de la quantité de données à importer ou à exporter. Pour de grandes quantités de données, divisez les données en plusieurs tâches.
- Vous ne pouvez créer une tâche de flux de données que sur un flux de données à l'état Running.
- Lorsque vous créez une tâche d'exportation, assurez-vous que la longueur totale du chemin absolu du fichier à exporter depuis CPFS for Lingjun ne dépasse pas 1 023 caractères.
- CPFS for Lingjun prend en charge deux types de tâches : les tâches par lot et les tâches en streaming. Pour plus d'informations, consultez Présentation des types de tâches.

Testez maintenant

Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale. Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale.

Test

Autorisation RAM

Le tableau ci-dessous décrit les autorisations nécessaires pour appeler cette API. Vous pouvez les définir dans une politique Resource Access Management (RAM). Les colonnes du tableau sont détaillées ci-dessous :

Action : les actions peuvent être utilisées dans l'élément Action des instructions de politique de permissions RAM pour accorder les autorisations nécessaires à l'exécution de l'opération.
API : l'API que vous pouvez appeler pour exécuter l'action.
Niveau d'accès : le niveau d'accès prédéfini accordé pour chaque API. Valeurs valides : create, list, get, update et delete.
Type de ressource : le type de ressource qui prend en charge l'autorisation pour exécuter l'action. Il indique si l'action prend en charge les permissions au niveau de la ressource. La ressource spécifiée doit être compatible avec l'action. Sinon, la politique sera inefficace.
- Pour les API avec permissions au niveau de la ressource, les types de ressource requis sont marqués d'un astérisque (*). Spécifiez l'Alibaba Cloud Resource Name (ARN) correspondant dans l'élément Resource de la politique.
- Pour les API sans permissions au niveau de la ressource, la valeur All Resources est affichée. Utilisez un astérisque (*) dans l'élément Resource de la politique.
Clé de condition : les clés de condition définies par le service. La clé permet un contrôle granulaire, applicable aux actions seules ou aux actions associées à des ressources spécifiques. En plus des clés de condition propres au service, Alibaba Cloud fournit un ensemble de clés de condition communes applicables à tous les services pris en charge par RAM.
Action dépendante : les actions dépendantes requises pour exécuter l'action. Pour mener à bien l'opération, l'utilisateur RAM ou le rôle RAM doit disposer des permissions pour toutes les actions dépendantes.

nas:CreateDataFlowTask

create

*DataFlow.

acs:nas:{#regionId}:{#accountId}:filesystem/{#filesystemId}

Aucune

Paramètres de requête

Paramètre	Type	Requis	Description	Exemple
FileSystemId	string	Oui	L'identifiant du système de fichiers. CPFS à usage général : l'identifiant doit commencer par cpfs-, par exemple cpfs-125487**. CPFS for Lingjun : l'identifiant doit commencer par bmcpfs-, par exemple bmcpfs-0015**.	cpfs-099394bd928c****
DataFlowId	string	Oui	L'identifiant du flux de données.	df-194433a5be31****
SrcTaskId	string	Non	Si vous spécifiez SrcTaskId, saisissez l'identifiant de la tâche de flux de données. Le système copie les informations des paramètres TaskAction, DataType et EntryList à partir de la tâche de flux de données spécifiée. Vous n'avez pas besoin de spécifier ces paramètres séparément. Remarque Les tâches de flux de données en streaming ne sont pas prises en charge.	task-29ee8e890f45****
ClientToken	string	Non	Le jeton client utilisé pour garantir l'idempotence de la requête. Vous pouvez utiliser le client pour générer le jeton, mais vous devez vous assurer que le jeton est unique pour chaque requête. Le jeton ne peut contenir que des caractères ASCII et sa longueur ne peut pas dépasser 64 caractères. Pour plus d'informations, consultez Comment garantir l'idempotence. Remarque Si vous ne spécifiez pas ce paramètre, le système utilise automatiquement le RequestId de la requête API comme ClientToken. Le RequestId peut être différent pour chaque requête API.	123e4567-e89b-12d3-a456-42665544****
DryRun	boolean	Non	Indique si un test à blanc doit être effectué pour cette requête. Un test à blanc vérifie la validité des paramètres, vérifie l'inventaire et effectue d'autres contrôles sans créer réellement l'instance ni engendrer de frais. Valeurs valides : true : envoie une requête de test à blanc sans créer l'instance. Les éléments de contrôle incluent la spécification des paramètres requis, le format de la requête, les limites métier et l'inventaire de File Storage NAS. Si le contrôle échoue, l'erreur correspondante est renvoyée. Si le contrôle réussit, le code d'état HTTP 200 est renvoyé, mais TaskId est vide. false (valeur par défaut) : envoie une requête normale. Une fois le contrôle réussi, l'instance est directement créée.	false
TaskAction	string	Non	Le type de nœud de flux de données. Valeurs valides : Import : importation de données depuis le stockage source vers CPFS. Export : exportation de données spécifiées depuis CPFS vers le stockage source. StreamImport : importation de données par lot depuis le stockage source vers CPFS. StreamExport : exportation de données spécifiées par lot depuis CPFS vers le stockage source. Evict : libère les blocs de données des fichiers sur CPFS. Après la libération, seules les métadonnées sont conservées sur CPFS. Vous pouvez toujours interroger le fichier, mais les blocs de données sont purgés et n'occupent pas de capacité de stockage sur CPFS. Lorsque vous accédez aux données du fichier, les données sont chargées à la demande depuis le stockage source. Inventory : obtient la liste des fichiers gérés par le flux de données sur CPFS. Cela fournit l'état du cache des fichiers dans le flux de données. Remarque CPFS for Lingjun prend uniquement en charge Import, Export, StreamImport et StreamExport. StreamImport et StreamExport sont pris en charge uniquement par CPFS for Lingjun 2.6.0 et les versions ultérieures. Valeurs valides : StreamExport : Exportation de données spécifiées par lot depuis CPFS vers le stockage source. Import : Importation de données depuis le stockage source vers CPFS. StreamImport : Importation de données spécifiées par lot depuis le stockage source vers CPFS. Export : Exportation de données spécifiées depuis CPFS vers le stockage source. Evict : Libère les blocs de données des fichiers sur CPFS. Après la libération, seules les métadonnées sont conservées sur CPFS. Inventory : Obtient la liste des fichiers gérés par le flux de données sur CPFS. Cela fournit l'état du cache des fichiers dans le flux de données.	Import
DataType	string	Non	Le type de données sur lequel la tâche de flux de données opère. Valeurs valides : Metadata : les métadonnées des fichiers, y compris les attributs tels que l'horodatage, la propriété et les permissions. Si vous sélectionnez Metadata, seules les métadonnées des fichiers sont importées. Vous pouvez voir le fichier, mais lorsque vous accédez aux données du fichier, les données sont chargées à la demande depuis le stockage source. Data : les blocs de données des fichiers. MetaAndData : les métadonnées et les blocs de données des fichiers. Remarque Lorsque TaskAction est défini sur Evict, le paramètre DataType est requis. Valeurs valides : : Metadata : Les métadonnées des fichiers. Data : Les blocs de données des fichiers. MetaAndData : Les métadonnées et les blocs de données des fichiers.	Metadata
Directory	string	Non	Le répertoire source des données. Limites : La valeur doit comporter entre 1 et 1 023 caractères. La valeur doit être encodée en UTF-8. La valeur doit commencer et se terminer par une barre oblique (/). Un seul répertoire peut être spécifié à la fois. Lorsque TaskAction est défini sur Export, ce répertoire doit être un chemin relatif dans FileSystemPath. Lorsque TaskAction est défini sur Import, ce répertoire doit être un chemin relatif dans SourceStoragePath. Lorsque TaskAction est défini sur StreamExport, ce répertoire doit être un chemin relatif dans FileSystemPath. Lorsque TaskAction est défini sur StreamImport, ce répertoire doit être un chemin relatif dans SourceStoragePath. Remarque StreamImport et StreamExport sont pris en charge uniquement par CPFS for Lingjun 2.6.0 et les versions ultérieures. Directory, EntryList et TransferFileListPath sont des paramètres mutuellement exclusifs. Vous ne pouvez en spécifier qu'un seul.	/path_in_cpfs/
EntryList	string	Non	La liste des fichiers sur lesquels la tâche de flux de données est exécutée. Limites : La valeur doit être encodée en UTF-8. La longueur totale de la liste de fichiers doit être inférieure à 64 Ko. La liste de fichiers doit être au format JSON. Le chemin de chaque fichier doit comporter entre 1 et 1 023 caractères et doit commencer par une barre oblique (/). Lorsque TaskAction est défini sur Import, chaque élément de la liste représente un nom d'objet OSS. Lorsque TaskAction est défini sur Export, chaque élément de la liste représente un chemin de fichier CPFS. Remarque Directory, EntryList et TransferFileListPath sont des paramètres mutuellement exclusifs. Vous ne pouvez en spécifier qu'un seul.	["/path_in_cpfs/file1", "/path_in_cpfs/file2"]
TransferFileListPath	string	Non	Le répertoire OSS. Les données sont synchronisées en fonction du contenu des fichiers CSV dans le répertoire OSS. Limites : La valeur doit commencer et se terminer par une barre oblique (/). La valeur est sensible à la casse. La valeur doit comporter entre 1 et 1 023 caractères. La valeur doit être encodée en UTF-8. Remarque TransferFileListPath, Directory et EntryList sont des paramètres mutuellement exclusifs. Vous ne pouvez en spécifier qu'un seul. Ce paramètre spécifie un chemin existant dans OSS. Les fichiers *.csv dans le chemin sont stockés dans OSS. TransferFileListPath prend uniquement en charge Import et Export. Pour Import, les fichiers ou répertoires spécifiés dans les fichiers CSV sont importés d'OSS vers CPFS. Pour Export, les fichiers ou répertoires spécifiés dans les fichiers CSV sont exportés de CPFS vers OSS. Le fichier CSV doit contenir les colonnes Name et Type. Name est un chemin relatif. Type prend en charge deux valeurs : dir et file. Si Type est dir, la valeur Name doit se terminer par une barre oblique (/). Seul CPFS for Lingjun prend en charge cette fonctionnalité.	/test_oss_path/
Includes	string	Non	Filtre les répertoires sous le répertoire spécifié et transfère le contenu des dossiers inclus. Remarque Ce paramètre prend effet uniquement lorsque le paramètre Directory est spécifié. Le chemin de chaque dossier doit comporter entre 1 et 1 023 caractères et doit commencer et se terminer par une barre oblique (/). La longueur totale ne peut pas dépasser 3 000 caractères. Seul CPFS for Lingjun prend en charge cette fonctionnalité.	["/test/","/test1/"]
DstDirectory	string	Non	Le répertoire cible auquel la tâche de flux de données est mappée. Limites : La valeur doit commencer et se terminer par une barre oblique (/). /../ n'est pas pris en charge. La valeur doit comporter entre 1 et 1 023 caractères. La valeur doit être encodée en UTF-8. Un seul répertoire peut être spécifié à la fois. Lorsque TaskAction est défini sur Export, ce répertoire doit être un chemin relatif dans SourceStoragePath. Lorsque TaskAction est défini sur Import, ce répertoire doit être un chemin relatif dans FileSystemPath. Lorsque TaskAction est défini sur StreamExport, ce répertoire doit être un chemin relatif dans SourceStoragePath. Lorsque TaskAction est défini sur StreamImport, ce répertoire doit être un chemin relatif dans FileSystemPath. Remarque StreamImport et StreamExport sont pris en charge uniquement par CPFS for Lingjun 2.6.0 et les versions ultérieures.	/path_in_cpfs/
CreateDirIfNotExist	boolean	Non	Indique si la création automatique du dossier doit être activée lorsqu'il n'existe pas. Valeurs valides : true : la création automatique du dossier est activée. false (valeur par défaut) : la création automatique du dossier n'est pas activée. Remarque Ce paramètre prend effet lorsque TaskAction est défini sur Import. Seul CPFS for Lingjun 2.6.0 et les versions ultérieures prennent en charge cette fonctionnalité.	false
ConflictPolicy	string	Non	La stratégie de conflit pour les fichiers portant le même nom. Valeurs valides : SKIP_THE_FILE : ignore les fichiers portant le même nom. KEEP_LATEST : compare l'heure de mise à jour et conserve la version la plus récente. OVERWRITE_EXISTING : écrase de force les fichiers portant le même nom. Remarque Ce paramètre est requis lorsque le type de système de fichiers est CPFS for Lingjun. Valeurs valides : KEEP_LATEST : Compare l'heure de mise à jour et conserve la version la plus récente. OVERWRITE_EXISTING : Écrase de force les fichiers portant le même nom. SKIP_THE_FILE : Ignore les fichiers portant le même nom.	SKIP_THE_FILE

Éléments de réponse

Élément	Type	Description	Exemple
	object
RequestId	string	L'identifiant de la requête.	2D69A58F-345C-4FDE-88E4-BF518948****
TaskId	string	L'identifiant de la tâche de flux de données.	task-38aa8e890f45****

Exemples

JSON format

{
  "RequestId": "2D69A58F-345C-4FDE-88E4-BF518948****",
  "TaskId": "task-38aa8e890f45****"
}

Codes d'erreur

Code de statut HTTP	Code d'erreur	Message d'erreur	Description
400	IllegalCharacters	The parameter contains illegal characters.	Paramètre non valide.
400	MissingFileSystemId	FileSystemId is mandatory for this action.	Le paramètre FileSystemId n'est pas spécifié.
400	MissingDataFlowId	DataFlowId is mandatory for this action.	Le paramètre DataFlowId n'est pas spécifié.
400	InvalidFilesystemVersion.NotSupport	This Api does not support this fileSystem version.	L'opération actuelle ne prend pas en charge cette version du système de fichiers.
403	OperationDenied.InvalidState	The operation is not permitted when the status is processing.	Cette opération n'est pas autorisée lorsque l'état est en cours de traitement.
403	OperationDenied.DependencyViolation	The operation is denied due to dependancy violation.	Les conditions requises pour cette opération ne sont pas remplies.
403	OperationDenied.DataFlowNotSupported	The operation is not supported.	Le système de fichiers ne prend pas en charge les flux de données.
404	InvalidParameter.InvalidFormat	The EntryList format is invalid.	Le format de l'EntryList spécifiée ne répond pas aux exigences.
404	InvalidParameter.SizeTooLarge	The specified EntryList size exceeds 64 KB.	La taille de l'EntryList spécifiée dépasse 64 Ko.
404	InvalidDataFlow.NotFound	The specified data flow does not exist.	Le flux de données spécifié n'existe pas.
404	InvalidTaskAction.NotSupported	The task action is not supported.	Le type de tâche spécifié n'est pas pris en charge.
404	InvalidTaskAction.PermissionDenied	The task action is not allowed.	Le type de tâche spécifié n'est pas autorisé, tel que la réplication du système.
404	InvalidSrcTaskId.NotFound	The SrcTaskId is not found.	Le SrcTaskId spécifié n'existe pas.
404	InvalidDataType.NotSupported	The data type is not supported.	Le type de données spécifié n'est pas pris en charge.
404	InvalidSrcTaskId.TaskIdInvalid	Source task ID is invalid.	L'identifiant de tâche à copier spécifié n'est pas valide.
404	InvalidSrcTaskId.TaskIdNotFound	Source task ID is not found.	L'identifiant de tâche à copier spécifié n'existe pas.

Consultez Codes d'erreur pour la liste complète.

Notes de version

Consultez Notes de version pour la liste complète.