Partager via

Transformer des données dans Azure Data Factory et Azure Synapse Analytics

  • Article

S’APPLIQUE À : Azure Data Factory Azure Synapse Analytics

Conseil

Essayez Data Factory dans Microsoft Fabric, une solution d’analyse tout-en-un pour les entreprises. Microsoft Fabric couvre tous les aspects, du déplacement des données à la science des données, en passant par l’analyse en temps réel, l’aide à la décision et la création de rapports. Découvrez comment démarrer un nouvel essai gratuitement !

Important

La prise en charge d’Azure Machine Learning Studio (classique) prend fin le 31 août 2024. Nous vous recommandons de passer à Azure Machine Learning avant cette date.

Depuis le 1er décembre 2021, vous ne pouvez plus créer de nouvelles ressources Machine Learning Studio (classique) (plan d’espace de travail et de service web). Jusqu’au 31 août 2024, vous pouvez continuer à utiliser les expériences et services web Machine Learning Studio (classique) existants. Pour plus d’informations, consultez l’article suivant :

La documentation de Machine Learning Studio (classique) est en cours de retrait et pourrait ne pas être mise à jour à l’avenir.

Vue d’ensemble

Cet article explique les activités de transformation des données dans les pipelines Azure Data Factory et Synapse, que vous pouvez utiliser pour transformer et traiter vos données brutes en vue d’en tirer des prédictions et des insights à grande échelle. Une activité de transformation s’exécute dans un environnement de calcul tel que Azure Databricks ou Azure HDInsight. Elle fournit des liens vers des articles contenant des informations détaillées sur chaque activité de transformation.

Le service prend en charge les activités de transformation des données suivantes, qui peuvent être ajoutées à des pipelines, soit individuellement soit de façon chaînée avec une autre activité.

Transformer des données en mode natif dans Azure Data Factory et Azure Synapse Analytics en utilisant des flux de données

Mappage des flux de données

Les flux de données de mappage sont des transformations de données conçues de manière graphique dans Azure Data Factory et Azure Synapse. Les flux de données permettent aux ingénieurs de données de développer une logique de transformation graphique des données sans rédiger de code. Les flux de données qui en résultent sont exécutés en tant qu’activités dans les pipelines qui utilisent des clusters Spark faisant l’objet d’un scale-out. Les activités de flux de données peuvent être mises en œuvre à l’aide de fonctionnalités de planification, de contrôle, de flux et de supervision existantes au sein du service. Pour plus d’informations, consultez les flux de données de mappage.

Data wrangling

Power Query dans Azure Data Factory vous permet le data wrangling à l’échelle du cloud, ce qui vous permet d’effectuer une préparation de données sans code à l’échelle du cloud de manière itérative. Le data wrangling s’intègre à Power Query Online et rend les fonctions Power Query M disponibles pour le data wrangling à l’échelle du cloud via l’exécution Spark. Pour plus d’informations, consultez Data wrangling dans Azure Data Factory.

Notes

Power Query est actuellement pris en charge dans Azure Data Factory, mais pas dans Azure Synapse. Pour obtenir la liste des fonctionnalités spécifiques prises en charge dans chaque service, consultez Fonctionnalités disponibles dans les pipelines Azure Data Factory et Azure Synapse Analytics.

Transformations externes

Si vous le souhaitez, vous pouvez coder manuellement les transformations et gérer l’environnement de calcul externe vous-même.

Activité Hive HDInsight

L’activité Hive HDInsight d’un pipeline exécute des requêtes Hive sur votre propre cluster ou cluster à la demande HDInsight sous Windows ou Linux. Consultez l’article Activité Hive pour obtenir plus de détails sur cette activité.

Activité Pig HDInsight

L’activité Pig HDInsight d’un pipeline exécute des requêtes Pig sur votre propre cluster ou cluster à la demande HDInsight sous Windows ou Linux. Consultez l’article Activité Pig pour obtenir plus de détails sur cette activité.

Activité MapReduce HDInsight

L’activité MapReduce HDInsight d’un pipeline exécute des programmes MapReduce sur votre propre cluster ou cluster à la demande HDInsight sous Windows ou Linux. Consultez l’article Activité MapReduce pour obtenir plus de détails sur cette activité.

Activité de diffusion en continu HDInsight

L’activité Streaming HDInsight d’un pipeline exécute des programmes Streaming Hadoop sur votre propre cluster ou cluster à la demande HDInsight sous Windows ou Linux. Consultez l’activité de diffusion en continu HDInsight pour plus d’informations sur cette activité.

Activité HDInsight Spark

L’activité Spark HDInsight d’un pipeline exécute des programmes Spark sur votre propre cluster HDInsight. Pour plus d’informations, consultez Appeler des programmes Spark avec Azure Data Factory ou Azure Synapse Analytics.

Activités ML Studio (classique)

Important

La prise en charge d’Azure Machine Learning Studio (classique) prend fin le 31 août 2024. Nous vous recommandons de passer à Azure Machine Learning avant cette date.

Depuis le 1er décembre 2021, vous ne pouvez plus créer de nouvelles ressources Machine Learning Studio (classique) (plan d’espace de travail et de service web). Jusqu’au 31 août 2024, vous pouvez continuer à utiliser les expériences et services web Machine Learning Studio (classique) existants. Pour plus d’informations, consultez l’article suivant :

La documentation de Machine Learning Studio (classique) est en cours de retrait et pourrait ne pas être mise à jour à l’avenir.

Le service vous permet de créer facilement des pipelines qui utilisent un service web ML Studio (classique) publié pour l’analyse prédictive. En utilisant l’activité Batch Execution dans un pipeline, vous pouvez appeler un service web ML Studio (classique) pour effectuer des prédictions sur les données par lot.

Au fil du temps, les modèles prédictifs dans les expériences de notation Studio (classique) doivent être reformés à l’aide de nouveaux jeux de données d’entrée. Une fois que vous avez fini la reformation, vous souhaitez mettre à jour le service Web de notation avec le modèle Machine Learning reformé. Vous pouvez utiliser l’activité des ressources de mise à jour pour mettre à jour le service web avec le modèle qui vient d’être formé.

Pour plus d’informations sur ces activités Studio (classique), consultez Utiliser des activités ML Studio (classique).

Activité de procédure stockée

Vous pouvez utiliser l’activité Procédure stockée SQL Server dans un pipeline Data Factory pour appeler une procédure stockée dans un des magasins de données suivants : Azure SQL Database, Azure Synapse Analytics ou SQL Server Database dans votre entreprise ou une machine virtuelle Azure. Consultez l’article Activité de procédure stockée pour plus de détails.

Activité U-SQL Data Lake Analytics

L’activité U-SQL Data Lake Analytics exécute un script U-SQL sur un cluster Azure Data Lake Analytics. Consultez l’article Activité U-SQL Data Analytics pour plus de détails.

Activité Azure Synapse Notebook

L’activité du notebook Azure Synapse dans un pipeline Synapse exécute un notebook Synapse dans votre espace de travail Azure Synapse. Consultez Transformer des données en exécutant un notebook Azure Synapse.

Activité Databricks Notebook

L’activité Azure Databricks Notebook dans un pipeline exécute un notebook Databricks dans votre espace de travail Azure Databricks. Azure Databricks est une plateforme gérée pour exécuter Apache Spark. Consultez Transformer des données en exécutant un bloc-notes Databricks.

Activité Databricks Jar

L’activité Azure Databricks Jar dans un pipeline exécute un fichier Spark Jar dans votre cluster Azure Databricks. Azure Databricks est une plateforme gérée pour exécuter Apache Spark. Consultez Transformer des données en exécutant une activité Jar dans Azure Databricks.

Activité Databricks Python

L’activité Azure Databricks Python dans un pipeline exécute un fichier Python dans votre cluster Azure Databricks. Azure Databricks est une plateforme gérée pour exécuter Apache Spark. Consultez Transformer des données en exécutant une activité Python dans Azure Databricks.

Activité personnalisée

Si vous devez transformer les données d’une manière qui n’est pas prise en charge par Data Factory, créez une activité personnalisée avec votre propre logique de traitement des données et utilisez cette activité dans le pipeline. Vous pouvez configurer l’activité .NET personnalisée pour l’exécuter en utilisant un service Azure Batch ou un cluster Azure HDInsight. Consultez l’article Utilisation des activités personnalisées pour plus de détails.

Vous pouvez créer une activité personnalisée pour exécuter des scripts R sur votre cluster HDInsight si R est installé. Consultez Exécuter des scripts R avec des pipelines Azure Data Factory et Synapse.

Environnements de calcul

Vous créez un service lié à l’environnement de calcul puis l’utilisez lorsque vous définissez une activité de transformation. Il existe deux types d’environnements de calcul pris en charge.

  • À la demande : dans ce cas, l’environnement de calcul est entièrement géré par le service. Il est automatiquement créé par le service avant qu'une tâche de traitement des données ne soit soumise, puis il est supprimé lorsque la tâche est terminée. Vous pouvez configurer et contrôler les paramètres granulaires de l’environnement de calcul à la demande pour l'exécution de la tâche, la gestion du cluster et les actions d’amorçage.
  • Apport de votre propre environnement (Bring Your Own) : dans ce cas, vous inscrivez votre propre environnement de calcul (par exemple, un cluster HDInsight) en tant que service lié. C’est vous qui gérez l'environnement de calcul, et le service l'utilise pour exécuter les activités.

Consultez l’article Services liés de calcul pour en savoir plus sur les services de calcul pris en charge.

Contenu connexe

Consultez le didacticiel suivant pour voir un exemple d’utilisation d’une activité de transformation : Didacticiel - Transformation des données à l’aide de Spark