Accéder à

Plug-ins Cloud Data Fusion

Plug-ins Cloud Data Fusion

Les plug-ins sont des modules personnalisables qui renforcent les fonctionnalités de Cloud Data Fusion. Voici une liste complète des plug-ins disponibles dans Cloud Data Fusion, mais vous pouvez également créer votre propre plug-in avec des API de plug-ins.

Nous contacter Nous contacter

Les plus populaires

Découvrez et accédez rapidement aux plug-ins Cloud Data Fusion les plus populaires.

BigQuery

Cette source lit l'intégralité du contenu d'une table BigQuery.

BigQuery multi-tables

Ce récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Table BigQuery

Ce récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Cloud Storage

Ce plug-in source lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Cloud Storage

Ce plug-in écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Plusieurs tables de base de données

Lit à partir de plusieurs tables d'une base de données. Utilisé avec les plug-ins multi-récepteurs, tels que les récepteurs multi-usages de Cloud Storage et les récepteurs multiples de BigQuery pour charger des données depuis l'intégralité d'une base de données dans un seul pipeline.

MySQL

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Oracle

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Salesforce

Cette source lit les objets sObject tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

SAP ODP

Se connecte à une source SAP pour l'extraction de données par lots et basées sur les modifications incrémentielles via le provisionnement de données opérationnelles (ODP).

SQL Server

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Google Cloud

Découvrez tous les plug-ins disponibles pour les produits Google Cloud, y compris Cloud Storage, BigQuery, Cloud Bigtable, Datastore, Pub/Sub et Google Workspace.

BigQuery

Cette source lit l'intégralité du contenu d'une table BigQuery.

Configurateur d'arguments BigQuery

Lit une table BigQuery pour récupérer les arguments à définir dans le pipeline.

BigQuery Execute

Ce plug-in exécute une requête SQL BigQuery.

BigQuery multi-tables

Ce récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Table BigQuery

Ce récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Cloud Bigtable

Récepteur par lot qui écrit des données dans Cloud Bigtable

Cloud Bigtable

Cette source lit les données depuis Cloud Bigtable.

Datastore

Cette source lit les données à partir de Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Datastore

Ce récepteur écrit les données dans Cloud Datastore. Datastore est une base de données de documents NoSQL conçue pour le scaling automatique et les hautes performances.

Firestore

Lit depuis Cloud Firestore dans des pipelines par lot.

Firestore

Plug-in pour écrire dans Cloud Firestore par lot et en flux continu.

Cloud Storage

Ce plug-in écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Cloud Storage

Ce plug-in source lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Configurateur d'arguments Cloud Storage

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

Cloud Storage Delete

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Cloud Storage Copy

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Cloud Storage Create

Ce plug-in crée des objets dans un bucket Cloud Storage.

Cloud Storage Done File Marker

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Cloud Storage Move

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

Cloud Storage multi-fichiers

Ce plug-in est utilisé conjointement avec la source MultiTableDatabase pour écrire des enregistrements issus de plusieurs bases de données dans des répertoires distincts.

Cloud DLP Decrypt

Déchiffre les données sensibles précédemment chiffrées via Cloud DLP (Cloud Data Loss Prevention) à l'aide d'une transformation de chiffrement réversible telle que le chiffrement préservant le format.

Filtre d'informations personnelles Cloud DLP

Sépare les enregistrements sensibles selon qu'ils correspondent à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention (DLP).

Cloud DLP Redact

Masque les enregistrements sensibles à l'aide de Cloud Data Loss Prevention (DLP) en appliquant des filtres DLP prédéfinis ou un modèle personnalisé défini par l'utilisateur.

Google Drive

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Google Drive

Le plug-in du récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Google Sheets

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Google Sheets

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

Pub/Sub

Ce récepteur écrit dans un sujet Pub/Sub dans les pipelines de streaming.

Pub/Sub

Cette opération permet de lire les données d'un abonnement Pub/Sub en temps réel.

Spanner

Ce récepteur écrit dans une table Cloud Spanner.

Spanner

Cette source lit les données dans une table Cloud Spanner.

Speech-to-Text

Ce plug-in convertit des fichiers audio en texte à l'aide de Speech-to-Text.

Agréger

Plug-ins permettant d'agréger des fonctions telles que avg, count, count(*), first, last, max, min, sum, collect en incluant les jointures de table, etc.

Grouper par

Regroupe les données selon un ou plusieurs champs, puis effectue des fonctions d'agrégation telles que avg, count, count(*), first, last, max, min, sum, collect sur chaque groupe.

Joiner

Joint les enregistrements d'une ou plusieurs entrées en fonction de clés de jointure. Compatible avec les jointures internes et externes, la sélection et le changement de nom des champs de sortie.

Top N

La fonction Top N renvoie les N enregistrements les plus élevés de l'ensemble d'entrées, selon les critères spécifiés dans la configuration du plug-in.

Agrégation de fenêtres

Applique les fonctions d'agrégation sur une fenêtre de données.

Alertes

Plug-ins pour les alertes.

E-mail

Envoie un e-mail à la fin de l'exécution du pipeline.

E-mail par SendGrid

Action permettant d'envoyer un e-mail à la fin de l'exécution d'un pipeline.

Cloud Storage Done File Marker

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Rappel HTTP

Effectue une requête HTTP à la fin de l'exécution d'un pipeline.

Éditeur d'alertes Kafka

Éditeur d'alertes Kafka qui vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

MariaDB

Exécute une requête MariaDB à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Netezza

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Oracle

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

PostgreSQL

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

SQL Server

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Teradata

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

TMS

Publie les alertes dans le système de messagerie transactionnelle (TMS) CDAP en tant qu'objets JSON.

Apache

Plug-ins pour Apache.

Cassandra

Récepteur par lot qui écrit des données dans Apache Cassandra.

Cassandra

Source par lots qui lit des données depuis Apache Cassandra.

HBase

Écrit des enregistrements dans une table HBase avec un mappage de champ sur la clé de ligne, et tous les autres champs d'enregistrement mappés aux qualificatifs de colonne.

HBase

Source par lots qui lit les données d'une famille de colonnes dans une table HBase.

Exportation groupée Hive

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Importation groupée Hive

Importe des données d'un répertoire/fichier dans une table Hive à l'aide de l'instruction Hive Load.

HTTP vers HDFS

Action permettant de récupérer des données à partir d'un point de terminaison HTTP externe et de créer un fichier dans HDFS.

Éditeur d'alertes Kafka

Éditeur d'alertes Kafka qui vous permet de publier des alertes sur Kafka en tant qu'objets JSON.

Consommateur Kafka

Source de lot Kafka qui lit les événements d'Apache Kafka dans des pipelines de traitement par lot.

Consommateur Kafka

Source de streaming Kafka qui lit les événements d'Apache Kafka dans des pipelines de streaming.

Kafka Producer

Récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Kudu

Plug-in CDAP pour ingérer des données dans Apache Kudu Le plug-in peut être configuré pour les pipelines par lot et en temps réel.

Kudu

Plug-in CDAP pour lire les données d'Apache Kudu

Programme PySpark

Exécute le code Spark fourni par l'utilisateur en Python.

Répartitionneur

Ce plug-in repartitionne un RDD Spark.

Scala Spark Compute

Exécute le code Spark fourni par l'utilisateur dans Scala, qui transforme le RDD en RDD avec un accès complet à toutes les fonctionnalités Spark.

Programme Scala Spark

Exécute le code Spark fourni par l'utilisateur dans Scala.

Spark

Exécute le code Spark fourni par l'utilisateur dans Scala et fonctionne sur un RDD ou un DataFrame d'entrée avec un accès complet à toutes les fonctionnalités Spark.

Analyseur de journaux de serveur Web

Analyse les journaux de n'importe quelle source d'entrée pour obtenir des informations pertinentes telles que l'URI, l'adresse IP, le navigateur, l'appareil, le code d'état HTTP et l'horodatage.

API

Plug-ins pour diverses API

Anaplan

Plug-in source permettant de charger des données depuis un modèle Anaplan dans un pipeline de données.

Anaplan

Plug-in de récepteur pour permettre l'importation de données de CDAP vers le serveur Anaplan.

Fonction Anaplan

Effectue une action/un processus prédéfini dans le modèle Anaplan donné. Ce type de certificat est le plus souvent utilisé pour vous préparer à l'importation et à l'exportation de données.

Annonces Facebook

Lit les données d'annonces de l'API Facebook Insights dans des pipelines de traitement par lot.

GitHub

Lit à partir de GitHub dans des pipelines de traitement par lot.

Rapports multiples Google Ads

Lit tous les rapports Google Ads à partir d'un compte Google Ads dans des pipelines de traitement par lot.

Rapport Google Ads unique

Lit le type de rapport spécifié à partir de comptes Google Ads dans des pipelines de traitement par lot.

Lot Google Analytics

Lit à partir de Google Analytics 360 dans les pipelines par lot.

Streaming Google Analytics

Lit à partir de Google Analytics 360 dans les pipelines de traitement par streaming.

Google Drive

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Google Drive

Le plug-in du récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Google Search Console

Lit à partir de Google Search Console dans des pipelines de traitement par lot.

Google Sheets

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Google Sheets

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

HTTP

Lit les données aux formats JSON, XML, CSV, TSV, TEXT et BLOB à partir des API HTTP/HTTPS dans des pipelines de traitement par lot.

HTTP

Plug-in de récepteur pour envoyer les messages du pipeline à un point de terminaison HTTP externe.

Rappel HTTP

Effectue une requête HTTP à la fin de l'exécution d'un pipeline.

Système d'interrogation HTTP

Il s'agit d'une source de streaming qui récupère des données à partir d'une URL spécifiée à un intervalle donné, puis transmet les résultats au plug-in suivant.

Streaming HTTP

Lit les données aux formats JSON, XML, CSV, TSV, TEXT et BLOB à partir des API HTTP/HTTPS dans les pipelines de streaming.

HTTP vers HDFS

Action permettant de récupérer des données à partir d'un point de terminaison HTTP externe et de créer un fichier dans HDFS.

HubSpot

Plug-in permettant d'écrire des données dans HubSpot CRM dans des pipelines par lot et par streaming.

HubSpot

Lit les données de HubSpot CRM dans les pipelines de traitement par flux.

HubSpot

Lit les données de HubSpot CRM dans les pipelines par lot.

Salesforce

Cette source lit les objets sObject tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Salesforce

Cette source effectue le suivi des mises à jour dans les objets sObject Salesforce. Les objets sObject peuvent être des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc.

Salesforce

Un récepteur par lot qui insère des objets sObject tels que des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc. dans Salesforce.

Salesforce Marketing Cloud

Cette source effectue le suivi des mises à jour dans les objets sObject Salesforce, tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc.

Salesforce Marketing Cloud

Ce récepteur insère des enregistrements dans une extension de données Salesforce Marketing Cloud (SFMC) via une intégration de serveur à serveur avec l'API SFMC.

Salesforce Multi Objects

Cette source lit plusieurs objets sObject de Salesforce. Il doit être utilisé avec des récepteurs multiples.

ServiceNow

Lit les données d'une ou de plusieurs tables dans ServiceNow.

Speech-to-Text

Ce plug-in convertit des fichiers audio en texte à l'aide de Speech-to-Text.

Splunk

Lit à partir de Splunk dans les pipelines de traitement par flux.

Splunk

Lit à partir de Splunk dans les pipelines par lot.

Zendesk

Lit les objets tels que les commentaires d'article, les commentaires de billets, les commentaires sur les demandes, les commentaires sur les tickets, les groupes, les organisations, les avis de satisfaction, les tags, les champs de tickets, les métriques de tickets, les événements de métriques de tickets, les tickets et les utilisateurs à partir de Zendesk.

Plusieurs objets Zendesk

Source multiple qui lit plusieurs objets depuis Zendesk et les achemine vers des destinations spécifiques. À utiliser avec un récepteur multiple.

Zuora

Plug-in permettant d'écrire des données dans Zuora par lots et en flux continu.

Zuora

Lit les données de Zuora dans des pipelines de traitement par lot.

Avro

Plug-ins pour Avro.

File

Écrit dans un système de fichiers dans divers formats.

File

Cette source est utilisée chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Cloud Storage

Écrit des enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

AWS

Plug-ins disponibles pour AWS.

Amazon S3

Cette source est utilisée chaque fois que vous avez besoin de lire des données depuis Amazon S3.

Amazon S3

Ce récepteur permet d'écrire dans Amazon S3 sous divers formats.

Client Amazon S3

L'action Client Amazon S3 permet de travailler avec des buckets et des objets S3 avant ou après l'exécution d'un pipeline.

Récepteur Kinesis

Récepteur Kinesis qui renvoie vers un flux Amazon Kinesis spécifié.

Source Kinesis

Source de streaming Spark qui lit les flux AWS Kinesis.

Redshift vers S3

L'action Redshift vers S3 exécute la commande UNLOAD sur AWS pour enregistrer les résultats d'une requête depuis Redshift dans un ou plusieurs fichiers sur Amazon S3.

S3 vers Redshift

L'action S3 vers Redshift charge les données du bucket AWS S3 dans la table AWS Redshift.

Nettoyage

Plug-ins pour le nettoyage.

Deduplicate

Déduplique les enregistrements à l'aide d'un ou de plusieurs champs, ou à l'aide de l'enregistrement dans son ensemble. En outre, il permet de choisir logiquement un enregistrement parmi les enregistrements en double en fonction d'un champ de filtre. Les fonctions logiques compatibles sont "max", "min", "first" et "last".

Distinct

Déduplique les enregistrements d'entrée afin que tous les enregistrements de sortie soient distincts.

Filtre rapide

Filtre les messages en fonction d'un critère spécifié.

Filtre d'informations personnelles Cloud DLP

Sépare les enregistrements sensibles selon qu'ils correspondent à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention (DLP).

Wrangler

Ce plug-in applique des instructions de transformation de données générées via une interface utilisateur interactive ou manuellement sur vos enregistrements de données.

Cloud Storage

Plug-ins disponibles pour le stockage dans le cloud.

Amazon S3

Cette source est utilisée chaque fois que vous avez besoin de lire des données depuis Amazon S3.

Azure Blob Store

Source par lot pour utiliser Microsoft Azure Blob Storage comme source.

Azure Decompress

Le plug-in d'action Azure Decompress décompresse les fichiers .gz d'un conteneur hébergé sur le service Azure Storage Blob dans un autre conteneur.

Cloud Storage vers Snowflake

Charge des données à partir de fichiers intermédiaires ou internes en préproduction dans Cloud Storage vers une table Snowflake existante.

Cloud Storage

Ce plug-in écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Cloud Storage

Ce plug-in source lit les objets d'un chemin d'accès dans un bucket Cloud Storage.

Configurateur d'arguments Cloud Storage

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

Cloud Storage Delete

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Cloud Storage Copy

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Cloud Storage Create

Ce plug-in crée des objets dans un bucket Cloud Storage.

Cloud Storage Move

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

Cloud Storage multi-fichiers

Ce plug-in est utilisé conjointement avec la source MultiTableDatabase pour écrire des enregistrements issus de plusieurs bases de données dans des répertoires distincts.

Cloud Storage Done File Marker

Crée un fichier DONE (ou SUCCESS) vide dans le bucket Cloud Storage donné en cas d'achèvement, de réussite ou d'échec du pipeline afin d'orchestrer les processus dépendants.

Microsoft Azure Delete

Le plug-in Azure Delete supprime un conteneur sur le service Blob Azure.

Snowflake vers Cloud Storage

Décharge les données d'une table Snowflake vers un emplacement Cloud Storage interne ou externe (étape).

Code

Plug-ins permettant d'exécuter votre propre code. 

JavaScript

Exécute le code JavaScript fourni par l'utilisateur qui transforme un enregistrement en zéro ou plusieurs enregistrements.

Programme PySpark

Exécute le code Spark fourni par l'utilisateur en Python.

Python Evaluator

Exécute le code Python fourni par l'utilisateur pour transformer les enregistrements d'entrée. Ceux-ci sont disponibles en tant que dictionnaire Python.

Scala Spark Compute

Exécute le code Spark fourni par l'utilisateur dans Scala, qui transforme le RDD en RDD avec un accès complet à toutes les fonctionnalités Spark.

Programme Scala Spark

Exécute le code Spark fourni par l'utilisateur dans Scala.

Spark

Exécute le code Spark fourni par l'utilisateur dans Scala et fonctionne sur un RDD ou un DataFrame d'entrée avec un accès complet à toutes les fonctionnalités Spark.

Compression

Plug-ins pour la compression.

Compresseur

Compresse les champs configurés à l'aide de différents algorithmes de compression, tels que SNAPPY, ZIP et GZIP.

Azure Decompress

L'action Decompress permet de développer les fichiers archivés ou compressés (.zip, .gz, .tar, .tar.gz, etc.) avant de poursuivre le traitement dans un pipeline.

Décompresseur de champ

Décompresse les champs configurés à l'aide d'algorithmes de compression tels que SNAPPY, ZIP et GZIP.

Conditionnel

Les pipelines offrent également des plug-ins de flux de contrôle sous la forme de conditions. Les plug-ins de condition vous permettent de diviser votre pipeline en deux chemins d'accès distincts, selon que le prédicat de condition spécifié prend la valeur "true" ou "false".

Conditionnel

Plug-in de flux de contrôle permettant une exécution conditionnelle dans les pipelines en fonction d'expressions.

Collecteur d'erreurs

Collecte les erreurs émises à l'étape précédente et ajoute un message d'erreur, un code et une étape à l'enregistrement.

Pipeline de défaillance

Récepteur par lot qui entraîne l'échec d'un pipeline immédiatement après la réception du premier enregistrement.

Null Field Splitter

Ce plug-in envoie les enregistrements associés à une valeur nulle pour un champ donné au port nul et ceux associés à une valeur non nulle pour le port non nul.

Decompress

Achemine un enregistrement vers un port approprié en fonction de l'évaluation d'une expression sur la valeur d'un ou de plusieurs champs.

Séparateur d'union

Le séparateur d'union est utilisé pour répartir les données selon un schéma d'union, de sorte que la logique spécifique au type puisse être effectuée en aval.

Flux de contrôle

Plug-ins pour un flux de contrôle.

Fonction Anaplan

Effectue une action/un processus prédéfini dans le modèle Anaplan donné. Ce type de certificat est le plus souvent utilisé pour vous préparer à l'importation et à l'exportation de données.

BigQuery Execute

Exécutez une requête SQL au début ou à la fin d'un pipeline.

Base de données

Action qui exécute une commande de base de données.

Requête de base de données

Exécute une requête de base de données à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution DB2

Action qui exécute une commande DB2.

Azure Decompress

L'action Decompress permet de développer les fichiers archivés ou compressés (.zip, .gz, .tar, .tar.gz, etc.) avant de poursuivre le traitement dans un pipeline.

File Contents Checketer

Ce plug-in d'action permet de vérifier si un fichier est vide ou si le contenu d'un fichier correspond à un format donné.

File Delete

Supprime un ou plusieurs fichiers.

File Move

Permet de déplacer un ou plusieurs fichiers.

FTP Copy

Copiez les fichiers du serveur FTP vers la destination indiquée.

FTP Put

Copiez des fichiers sur le serveur FTP à partir d'une destination spécifiée.

Cloud Storage Delete

Ce plug-in supprime des objets dans un bucket Cloud Storage.

Cloud Storage Copy

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez copier un seul objet ou un répertoire d'objets.

Cloud Storage Create

Ce plug-in crée des objets dans un bucket Cloud Storage.

Cloud Storage Move

Ce plug-in copie les objets d'un bucket Cloud Storage à un autre. Vous pouvez déplacer un seul objet ou un répertoire d'objets.

HTTP vers HDFS

Action permettant de récupérer des données à partir d'un point de terminaison HTTP externe et de créer un fichier dans HDFS.

Exécution MariaDB

Action qui exécute une commande MariaDB.

Exécution MySQL

Action qui exécute une commande MySQL.

Exécution Netezza

Action qui exécute une commande Netezza.

Exécution Oracle

Action qui exécute une commande Oracle.

Oracle Export

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

PostgreSQL

Action qui exécute une commande PostgreSQL.

Redshift vers S3

L'action Redshift vers S3 exécute la commande UNLOAD sur AWS pour enregistrer les résultats d'une requête depuis Redshift dans un ou plusieurs fichiers sur Amazon S3.

Exécuteur de programmes à distance

Établissement d'une connexion SSH avec une machine distante pour exécuter la commande sur cette machine.

S3 vers Redshift

L'action S3 vers Redshift charge les données du bucket AWS S3 dans la table AWS Redshift.

SFTP Copy

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

SFTP Delete

Plug-in d'actions CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

SFTP Put

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Les expressions régulières de fichier permettent également de filtrer uniquement les fichiers qui vous intéressent.

Snowflake Run SQL

Exécute une requête SQL spécifiée dans Snowflake.

SQL Server Execute

Action qui exécute une commande SQL Server.

Teradata Execute

Action qui exécute une commande Teradata.

Windows Share Copy

Copie un ou plusieurs fichiers d'un partage Microsoft Windows sur un système de fichiers.

CRM

Plug-ins pour les plates-formes CRM telles que Salesforce.

HubSpot

Plug-in permettant d'écrire des données dans HubSpot CRM dans des pipelines par lot et par streaming.

HubSpot

Lit les données de HubSpot CRM dans les pipelines de traitement par flux.

HubSpot

Lit les données de HubSpot CRM dans les pipelines par lot.

Salesforce

Cette source lit les objets sObject tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc. à partir de Salesforce.

Salesforce

Un récepteur par lot qui insère des objets sObject tels que des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc. dans Salesforce.

Salesforce

Cette source effectue le suivi des mises à jour dans les objets sObject Salesforce. Les objets sObject peuvent être des opportunités, des contacts, des comptes, des prospects, tout objet personnalisé, etc.

Salesforce Marketing Cloud

Cette source effectue le suivi des mises à jour dans les objets sObject Salesforce, tels que les opportunités, les contacts, les comptes, les prospects, tout objet personnalisé, etc.

Salesforce Marketing Cloud

Ce récepteur insère des enregistrements dans une extension de données Salesforce Marketing Cloud (SFMC) via une intégration de serveur à serveur avec l'API SFMC.

Salesforce Multi Objects

Cette source lit plusieurs objets sObject de Salesforce. Elle doit être utilisée avec des récepteurs multiples.

CSV

Plug-ins pour CSV.

Mise en forme CSV

Met en forme la saisie dans un enregistrement CSV à l'aide de formats tels que DELIMITED, EXCEL, MYSQL, RFC4180 et TDF.

Analyseur de fichiers CSV

Analyse un enregistrement CSV au format DEFAULT, EXCEL, MYSQL, RFC4180, Délimité par des tabulations, Pipe délimité en un enregistrement structuré.

File

Écrit dans un système de fichiers dans divers formats.

File

Cette source est utilisée chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

Cloud Storage

Ce plug-in écrit les enregistrements dans un ou plusieurs fichiers d'un répertoire Cloud Storage sous différents formats tels que CSV, Avro, Parquet et JSON.

Kafka Producer

Récepteur Kafka qui vous permet d'écrire des événements au format CSV ou JSON dans Kafka.

Base de données

Plug-ins pour vos bases de données.

Cloud Bigtable

Récepteur par lot qui écrit des données dans Cloud Bigtable

Cloud Bigtable

Cette source lit les données depuis Cloud Bigtable.

Base de données

Action qui exécute une commande de base de données.

Base de données

Lit les données à partir d'une base de données à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Base de données

Écrit des enregistrements dans une table de base de données. Chaque enregistrement est écrit sur une ligne de la table.

Database Argument Setter

Lit une table de base de données relationnelle pour récupérer les arguments à définir dans le pipeline.

Requête de base de données

Exécute une requête de base de données à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

DB2

Lit les données à partir d'une table DB2 à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

DB2

Exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution DB2

Action qui exécute une commande DB2.

IBM DB2

Écrit des enregistrements dans une table DB2. Chaque enregistrement est écrit sur une ligne de la table.

MariaDB

Écrit des enregistrements dans une table MariaDB. Chaque enregistrement est écrit sur une ligne de la table.

MariaDB

Lit les données à partir d'une table MariaDB à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

MariaDB

Exécute une requête MariaDB à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution MariaDB

Action qui exécute une commande MariaDB.

Plusieurs tables de base de données

Lit à partir de plusieurs tables d'une base de données. Utilisé avec les plug-ins multi-récepteurs, tels que le récepteur multi-utilisateur Cloud Storage et le multi-récepteur BigQuery pour charger des données issues d'une base de données entière dans un seul pipeline.

MySQL Query

Exécute une requête MySQL à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

MySQL

Écrit des enregistrements dans une table MySQL. Chaque enregistrement est écrit sur une ligne de la table.

MySQL

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécution MySQL

Action qui exécute une commande MySQL.

Oracle

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Oracle

Écrit des enregistrements dans une table Oracle. Chaque enregistrement est écrit sur une ligne de la table.

Oracle

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution Oracle

Action qui exécute une commande Oracle.

Oracle Export

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

PostgreSQL

Lit les données à partir d'une requête PostgreSQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

PostgreSQL

Écrit des enregistrements dans une table PostgreSQL. Chaque enregistrement est écrit sur une ligne de la table.

PostgreSQL

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

PostgreSQL

Action qui exécute une commande PostgreSQL.

Spanner

Ce récepteur écrit dans une table Cloud Spanner.

Spanner

Cette source lit les données dans une table Cloud Spanner.

SQL Server

Écrit des enregistrements dans une table SQL Server. Chaque enregistrement est écrit sur une ligne de la table.

SQL Server

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

SQL Server

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

SQL Server Execute

Action qui exécute une commande SQL Server.

Cloud SQL

DB2 exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Entrepôt de données

Plug-ins pour votre entrepôt de données.

BigQuery

Cette source lit l'intégralité du contenu d'une table BigQuery.

Configurateur d'arguments BigQuery

Lit une table BigQuery pour récupérer les arguments à définir dans le pipeline.

BigQuery Execute

Ce plug-in exécute une requête SQL BigQuery.

BigQuery multi-tables

Ce récepteur écrit dans plusieurs tables BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Table BigQuery

Ce récepteur écrit les données dans une table BigQuery. Les données sont d'abord écrites dans un emplacement temporaire sur Cloud Storage, puis chargées dans BigQuery à partir de là.

Cloud Storage vers Snowflake

Charge des données à partir de fichiers intermédiaires ou internes en préproduction dans Cloud Storage vers une table Snowflake existante.

Exportation groupée Hive

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Importation groupée Hive

Importe des données d'un répertoire/fichier dans une table Hive à l'aide de l'instruction Hive Load.

Netezza

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit sur une ligne de la table.

Netezza

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable Génère un enregistrement pour chaque ligne renvoyée par la requête.

Netezza

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution Netezza

Action qui exécute une commande Netezza.

Redshift vers S3

L'action Redshift vers S3 exécute la commande UNLOAD sur AWS pour enregistrer les résultats d'une requête depuis Redshift dans un ou plusieurs fichiers sur Amazon S3.

S3 vers Redshift

L'action S3 vers Redshift charge les données du bucket AWS S3 dans la table AWS Redshift.

SCD2 Spark Compute

Crée une représentation SCD2 d'un enregistrement en regroupant les enregistrements sources par la clé spécifiée et en générant les dates de début et de fin (expiration).

Snowflake

Écrit des données dans une table Snowflake dans les pipelines par lot.

Snowflake

Lit les données des tables Snowflake dans les pipelines par lot.

Snowflake Run SQL

Exécute une requête SQL spécifiée dans Snowflake.

Snowflake vers Cloud Storage

Décharge les données d'une table Snowflake vers un emplacement Cloud Storage interne ou externe (étape).

Teradata

Écrit des enregistrements dans une table Teradata. Chaque enregistrement est écrit sur une ligne de la table.

Teradata

Lit les données à partir de Teradata à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Teradata

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Teradata

Action qui exécute une commande Teradata.

Action d'exportation groupée Vertica

Exporte de façon groupée les données contenues dans une table Vertica dans un fichier.

Action d'importation groupée Vertica

Le plug-in d'action d'importation groupée d'éléments Vertica lit tous les fichiers d'un répertoire donné et importe leur contenu de manière groupée dans une table Vertica.

DLP

Plug-ins pour Cloud Data Loss Prevention (DLP).

Cloud DLP Decrypt

Déchiffre les données sensibles précédemment chiffrées via Cloud DLP (Cloud Data Loss Prevention) à l'aide d'une transformation de chiffrement réversible telle que le chiffrement préservant le format.

Filtre d'informations personnelles Cloud DLP

Sépare les enregistrements sensibles selon qu'ils correspondent à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention (DLP).

Cloud DLP Redact

Masque les enregistrements sensibles à l'aide de Cloud Data Loss Prevention (DLP) en appliquant des filtres DLP prédéfinis ou un modèle personnalisé défini par l'utilisateur.

Dynamique

Plug-ins dynamiques.

Argument Setter

Effectue une requête HTTP pour récupérer les arguments à définir dans le pipeline.

Database Argument Setter

Lit une table de base de données relationnelle pour récupérer les arguments à définir dans le pipeline.

Configurateur d'arguments Cloud Storage

Lit dans un fichier Cloud Storage pour récupérer les arguments à définir dans le pipeline.

E-mail

Plug-ins pour la messagerie.

E-mail

Envoie un e-mail à la fin de l'exécution du pipeline.

E-mail par SendGrid

Action permettant d'envoyer un e-mail à la fin de l'exécution d'un pipeline.

SendGrid

Lit les données sur les campagnes marketing existantes, les analyses d'e-mails, les rebonds et les rapports de spam depuis SendGrid.

SendGrid

Écrit des données dans SendGrid par lots et en flux continu.

File

Plug-ins de fichier.

Mise en forme CSV

Met en forme la saisie dans un enregistrement CSV à l'aide de formats tels que DELIMITED, EXCEL, MYSQL, RFC4180 et TDF.

Analyseur de fichiers CSV

Analyse un enregistrement CSV au format DEFAULT, EXCEL, MYSQL, RFC4180, Délimité par des tabulations, Pipe délimité en un enregistrement structuré.

File

Écrit dans un système de fichiers dans divers formats.

File

Cette source est utilisée chaque fois que vous devez lire des données à partir d'un système de fichiers distribué.

File

Source de streaming de fichiers qui surveille un répertoire et diffuse le contenu des nouveaux fichiers ajoutés au répertoire.

File Appender

Ce plug-in de récepteur ajoute du contenu à un fichier existant jusqu'à ce qu'il atteigne un seuil d'âge ou une taille.

File Contents Checketer

Ce plug-in d'action permet de vérifier si un fichier est vide ou si le contenu d'un fichier correspond à un format donné.

File Delete

Supprime un ou plusieurs fichiers.

File Move

Permet de déplacer un ou plusieurs fichiers.

FTP

Source de lecture par lots à partir de FTP (ftp://..) ou SFTP (sftp://...).

FTP Copy

Copiez les fichiers du serveur FTP vers la destination indiquée.

FTP Put

Copiez des fichiers sur le serveur FTP à partir d'une destination spécifiée.

PDF Extractor

Cette transformation exploite la bibliothèque Apache PDF Box pour extraire le texte et les métadonnées d'un fichier PDF.

Redshift vers S3

L'action Redshift vers S3 exécute la commande UNLOAD sur AWS pour enregistrer les résultats d'une requête depuis Redshift dans un ou plusieurs fichiers sur Amazon S3.

Amazon S3

Ce récepteur permet d'écrire dans Amazon S3 sous divers formats.

S3 vers Redshift

L'action S3 vers Redshift charge les données du bucket AWS S3 dans la table AWS Redshift.

SFTP Copy

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

SFTP Delete

Plug-in d'actions CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

SFTP Put

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Les expressions régulières de fichier permettent également de filtrer uniquement les fichiers qui vous intéressent.

Filter

Plug-ins de filtrage.

Deduplicate

Déduplique les enregistrements à l'aide d'un ou de plusieurs champs, ou à l'aide de l'enregistrement dans son ensemble. En outre, il permet de choisir logiquement un enregistrement parmi les enregistrements en double en fonction d'un champ de filtre. Les fonctions logiques compatibles sont "max", "min", "first" et "last".

Distinct

Déduplique les enregistrements d'entrée afin que tous les enregistrements de sortie soient distincts.

Filtre rapide

Filtre les messages en fonction d'un critère spécifié.

Filtre d'informations personnelles Cloud DLP

Sépare les enregistrements sensibles selon qu'ils correspondent à un modèle défini par l'utilisateur à l'aide des API Cloud Data Loss Prevention (DLP).

Null Field Splitter

Ce plug-in envoie les enregistrements associés à une valeur nulle pour un champ donné au port nul et ceux associés à une valeur non nulle pour le port non nul.

Échantillonnage

Cette méthode échantillonne un ensemble de données volumineux circulant à l'aide de ce plug-in pour extraire des enregistrements aléatoires à l'aide d'un échantillonnage systématique ou "réservoir".

Top N

La fonction Top N renvoie les N enregistrements les plus élevés de l'ensemble d'entrées, selon les critères spécifiés dans la configuration du plug-in.

FTP

Plug-ins FTP.

FTP

Source de lecture par lots à partir de FTP (ftp://..) ou SFTP (sftp://...).

FTP Copy

Copiez les fichiers du serveur FTP vers la destination indiquée.

FTP Put

Copiez des fichiers sur le serveur FTP à partir d'une destination spécifiée.

SFTP Copy

La copie SFTP permet de copier les fichiers du répertoire spécifié sur les serveurs SFTP vers la destination indiquée.

SFTP Delete

Plug-in d'actions CDAP pour supprimer les fichiers spécifiés d'un serveur SFTP.

SFTP Put

La fonctionnalité SFTP Put permet d'importer les fichiers du système de fichiers (local/HDFS) sur le serveur FTP. Les expressions régulières de fichier permettent également de filtrer uniquement les fichiers qui vous intéressent.

Google Ads

Plug-ins pour Google Ads.

Rapports multiples Google Ads

Lit tous les rapports Google Ads à partir d'un compte Google Ads dans des pipelines de traitement par lot.

Rapport Google Ads unique

Lit le type de rapport spécifié à partir de comptes Google Ads dans des pipelines de traitement par lot.

Google Search Console

Lit à partir de Google Search Console dans des pipelines de traitement par lot.

Google Analytics 360

Plug-ins pour Google Analytics 360.

Lot Google Analytics

Lit à partir de Google Analytics 360 dans les pipelines par lot.

Streaming Google Analytics

Lit à partir de Google Analytics 360 dans les pipelines de traitement par streaming.

Google Workspace

Plug-ins pour Google Workspace, y compris Google Sheets et Google Drive.

Google Drive

Lit des fichiers du répertoire Google Drive spécifié via l'API Google Drive.

Google Drive

Le plug-in du récepteur enregistre les fichiers du pipeline dans le répertoire Google Drive via l'API Google Drive.

Google Sheets

Lit les feuilles de calcul à partir du répertoire Google Drive spécifié.

Google Sheets

Écrit des feuilles de calcul dans le répertoire Google Drive spécifié.

Hadoop

Plug-ins pour Hadoop.

HBase

Écrit des enregistrements dans une table HBase avec un mappage de champ sur la clé de ligne, et tous les autres champs d'enregistrement mappés aux qualificatifs de colonne.

HBase

Source par lots qui lit les données d'une famille de colonnes dans une table HBase.

Exportation groupée Hive

Hive Export prend une requête de sélection comme entrée pour exécuter cette requête sur une table Hive et stocker les résultats à l'emplacement spécifié.

Importation groupée Hive

Importe des données d'un répertoire/fichier dans une table Hive à l'aide de l'instruction Hive Load.

HTTP vers HDFS

Action permettant de récupérer des données à partir d'un point de terminaison HTTP externe et de créer un fichier dans HDFS.

HDFS

Plug-ins pour HDFS.

XML Reader

Le plug-in XML Reader est un plug-in source qui permet aux utilisateurs de lire des fichiers XML stockés sur HDFS.

HTTP vers HDFS

Action permettant de récupérer des données à partir d'un point de terminaison HTTP externe et de créer un fichier dans HDFS.

HP

Plug-ins pour HP.

Action d'exportation groupée Vertica

Exporte de façon groupée les données contenues dans une table Vertica dans un fichier.

Action d'importation groupée Vertica

Le plug-in d'action d'importation groupée d'éléments Vertica lit tous les fichiers d'un répertoire donné et importe leur contenu de manière groupée dans une table Vertica.

HTTP

Plug-ins pour HTTP.

Argument Setter

Effectue une requête HTTP pour récupérer les arguments à définir dans le pipeline.

IBM

Plug-ins pour IBM.

DB2

Lit les données à partir d'une table DB2 à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

DB2

Exécute une requête DB2 à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution DB2

Action qui exécute une commande DB2.

IBM DB2

Écrit des enregistrements dans une table DB2. Chaque enregistrement est écrit sur une ligne de la table.

Netezza

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit sur une ligne de la table.

Netezza

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable Génère un enregistrement pour chaque ligne renvoyée par la requête.

Netezza

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution Netezza

Action qui exécute une commande Netezza.

JDBC

Plug-ins pour JDBC.

Base de données

Lit les données à partir d'une base de données à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Base de données

Écrit des enregistrements dans une table de base de données. Chaque enregistrement est écrit sur une ligne de la table.

MongoDB

Lit les documents d'une collection MongoDB et convertit chaque document en un StructuredRecord à l'aide d'un schéma spécifié.

MongoDB

Ce récepteur écrit dans une collection MongoDB.

MySQL Query

Exécute une requête MySQL à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

MySQL

Écrit des enregistrements dans une table MySQL. Chaque enregistrement est écrit sur une ligne de la table.

MySQL

Lit les données à partir d'une instance MySQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Exécution MySQL

Action qui exécute une commande MySQL.

Netezza

Écrit des enregistrements dans une table Netezza. Chaque enregistrement est écrit sur une ligne de la table.

Netezza

Lit les données à partir d'une table Netezza à l'aide d'une requête SQL configurable Génère un enregistrement pour chaque ligne renvoyée par la requête.

Netezza

Exécute une requête Netezza à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution Netezza

Action qui exécute une commande Netezza.

Oracle

Lit dans une table Oracle à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Oracle

Écrit des enregistrements dans une table Oracle. Chaque enregistrement est écrit sur une ligne de la table.

Oracle

Exécute une requête Oracle à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Exécution Oracle

Action qui exécute une commande Oracle.

Oracle Export

Plug-in d'action permettant d'exporter efficacement les données Oracle vers un système de fichiers à l'aide des outils de ligne de commande d'Oracle.

PostgreSQL

Lit les données à partir d'une requête PostgreSQL à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

PostgreSQL

Écrit des enregistrements dans une table PostgreSQL. Chaque enregistrement est écrit sur une ligne de la table.

PostgreSQL

Exécute une requête PostgreSQL à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

PostgreSQL

Action qui exécute une commande PostgreSQL.

SQL Server

Écrit des enregistrements dans une table SQL Server. Chaque enregistrement est écrit sur une ligne de la table.

SQL Server

Exécute une requête SQL Server à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

SQL Server

Lit les données à partir de SQL Server à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

SQL Server Execute

Action qui exécute une commande SQL Server.

Teradata

Écrit des enregistrements dans une table Teradata. Chaque enregistrement est écrit sur une ligne de la table.

Teradata

Lit les données à partir de Teradata à l'aide d'une requête SQL configurable. Génère un enregistrement pour chaque ligne renvoyée par la requête.

Teradata

Exécute une requête Teradata à la fin de l'exécution du pipeline. Peut être configurée pour une exécution seulement en cas de réussite, seulement en cas d'échec, ou systématiquement à la fin de l'exécution.

Teradata Execute

Action qui exécute une commande Teradata.

JSON

Plug-ins pour JSON.