Ir a
Complementos de Cloud Data Fusion

Complementos de Cloud Data Fusion

Los complementos son módulos personalizables que amplían las posibilidades de Cloud Data Fusion. A continuación, se muestra una lista completa de los complementos disponibles en Cloud Data Fusion, pero también puedes crear tu propio complemento con APIs de complementos.

Contactar Contactar

Más popular

Descubre y accede rápidamente a los complementos más populares de Cloud Data Fusion.
BigQuery
Esta fuente lee todo el contenido de una tabla de BigQuery.
Multitabla de BigQuery
Este sumidero escribe en varias tablas de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Tabla de BigQuery
Este sumidero escribe en una tabla de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Cloud Storage
Este complemento de fuente lee objetos de una ruta en un segmento de Cloud Storage.
Cloud Storage
Este complemento de sumidero escribe registros en uno o varios archivos de un directorio de Cloud Storage en diversos formatos, como CSV, Avro, Parquet y JSON.
Multitabla de base de datos
Lee varias tablas de una base de datos. Se utiliza con complementos de varios sumideros, como el sumidero múltiple de Cloud Storage y el de BigQuery, para cargar los datos de toda la base de datos en un solo flujo de procesamiento.
MySQL
Lee datos de una instancia de MySQL mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Oracle
Lee datos de una tabla de Oracle mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Salesforce
En esta fuente se leen objetos de Salesforce como oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc. de Salesforce por lotes.
ODP de SAP
Se conecta a una fuente de SAP mediante la extracción de datos basada en lotes y basadas en deltas a través de aprovisionamiento de datos operativos (ODP).
SQL Server
Lee datos de SQL Server mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.

Google Cloud

Consulta todos los complementos disponibles para los productos de Google Cloud, como Cloud Storage, BigQuery, Cloud Bigtable, Datastore, Pub/Sub y Google Workspace.
BigQuery
Esta fuente lee todo el contenido de una tabla de BigQuery.
Establecedor de argumento de BigQuery
Lee datos de una tabla de BigQuery para obtener argumentos y configurar el flujo de procesamiento.
Ejecución de BigQuery
Este complemento ejecuta una consulta SQL de BigQuery.
Multitabla de BigQuery
Este sumidero escribe en varias tablas de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Tabla de BigQuery
Este sumidero escribe en una tabla de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Cloud Bigtable
Sumidero por lotes que escribe datos en Cloud Bigtable.
Cloud Bigtable
Esta fuente lee datos de Cloud Bigtable.
Sumidero de Dataplex
Ingiere datos en cualquiera de los recursos compatibles con Dataplex.
Fuente de Dataplex
Lee datos de entidades de Dataplex (tablas) que se encuentran en los recursos de Cloud Storage o de BigQuery.
Datastore
Esta fuente lee datos del almacén de datos. Datastore es una base de datos de documentos NoSQL creada para el escalado automático y el alto rendimiento.
Datastore
Este sumidero escribe datos en Cloud Datastore. Datastore es una base de datos de documentos NoSQL creada para el escalado automático y el alto rendimiento.
Firestore
Lee en Cloud Firestore en flujos de procesamiento por lotes.
Firestore
Complemento para escribir en Cloud Firestore en flujos de procesamiento por lotes y en streaming.
Cloud Storage
Este complemento de sumidero escribe registros en uno o varios archivos de un directorio de Cloud Storage en diversos formatos, como CSV, Avro, Parquet y JSON.
Cloud Storage
Este complemento de fuente lee objetos de una ruta en un segmento de Cloud Storage.
Configurador de argumentos de Cloud Storage
Lee datos de un archivo de Cloud Storage para obtener argumentos que se puedan definir en el flujo de procesamiento.
Eliminación de Cloud Storage
Este complemento elimina objetos de un segmento de Cloud Storage.
Copia de Cloud Storage
Este complemento copia objetos de un segmento de Cloud Storage en otro. Se puede copiar un único objeto o un directorio de objetos.
Creación de Cloud Storage
Este complemento crea objetos en un segmento de Cloud Storage.
Marcador de archivo listo de Cloud Storage
Crea un archivo DONE (o CORRECTO) vacío en el segmento de Cloud Storage indicado al finalizar el proceso, o en caso de éxito o fallo, para orquestar los procesos dependientes.
Traslado de Cloud Storage
Este complemento mueve objetos de un segmento de Cloud Storage a otro. Se puede mover un solo objeto o un directorio de objetos.
Multiarchivo de Cloud Storage
Este complemento se utiliza junto con la fuente MultiTableDatabase para escribir registros de varias bases de datos en directorios independientes.
Descifrado de Cloud DLP
Descifra datos sensibles que anteriormente se encriptaban con Cloud Data Loss Prevention (DLP) mediante una transformación reversible, como el encriptado con preservación de formato.
Filtro de información personal identificable de Cloud DLP
Separa los registros sensibles en función de si coinciden con una plantilla definida por el usuario mediante las APIs de Cloud Data Loss Prevention (DLP).
Ocultar datos de Cloud DLP
Oculta registros sensibles con Cloud Data Loss Prevention (DLP) al usar filtros predefinidos de DLP o una plantilla personalizada definida por el usuario.
Google Drive
Lee archivos del directorio de Google Drive especificado a través de la API de Google Drive.
Google Drive
El complemento de sumidero guarda los archivos del flujo de procesamiento en el directorio de Google Drive mediante la API de Google Drive.
Hojas de cálculo de Google
Escribe hojas de cálculo en el directorio de Google Drive especificado.
Hojas de cálculo de Google
Lee hojas de cálculo del directorio de Google Drive especificado.
Pub/Sub
Este sumidero escribe en un tema de Pub/Sub en flujos de procesamiento de streaming.
Pub/Sub
Fuente que lee datos de una suscripción de Pub/Sub en tiempo real.
Spanner
Este sumidero escribe en una tabla de Cloud Spanner.
Spanner
La fuente se lee a partir de una tabla de Cloud Spanner.
Speech‑to‑Text
Este complemento convierte Speech‐to‐Text en archivos de audio a texto.

Agregar

Complementos para agregar funciones como promedio, recuento, recuento(*), primero, último, máximo, mínimo, suma, recoger, incluidas combinaciones de tablas, etc.
Agrupar por
Agrupa por uno o varios campos y, a continuación, realiza funciones de agregación, como las de media, recuento, recuento(*), primero, último, máximo, mínimo, suma y recoger en cada grupo.
Carpintero
Une los registros de una o varias entradas según las claves de join. Admite la unión interna y la externa, la selección y el cambio de nombre de los campos de salida.
Los primeros N
Los primeros N devuelven los "n" registros principales del conjunto de entrada, según los criterios especificados en la configuración del complemento.
Agregación de ventanas
Aplica funciones de agregación en una ventana de datos.

Alertas

Complementos para alertas.
Correo electrónico
Envía un correo electrónico al final de una ejecución de flujo de procesamiento.
Correo de SendGrid
Acción para enviar un correo electrónico al final de una ejecución de flujo de procesamiento.
Marcador de archivo listo de Cloud Storage
Crea un archivo DONE (o CORRECTO) vacío en el segmento de Cloud Storage indicado al finalizar el proceso, o en caso de éxito o fallo, para orquestar los procesos dependientes.
Retrollamada HTTP
Realiza una solicitud HTTP al final de la ejecución de un flujo de procesamiento.
Editor de alertas de Kafka
El editor de alertas de Kafka te permite publicar alertas en Kafka como objetos JSON.
MariaDB
Ejecuta una consulta de MariaDB al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Netezza
Ejecuta una consulta de Netezza al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Oracle
Ejecuta una consulta de Oracle al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
PostgreSQL
Ejecuta una consulta de PostgreSQL al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
SQL Server
Ejecuta una consulta de SQL Server al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
TeraData
Ejecuta una consulta de Teradata al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
TMS
Publica alertas en el sistema de mensajes de transacción (TMS) de CDAP como objetos JSON.

Apache

Complementos para Apache.
Cassandra
Sumidero por lotes que escribe datos en Apache Cassandra.
Cassandra
Origen de procesamiento por lotes que lee desde Apache Cassandra.
HBase
Escribe registros en una tabla de HBase con una asignación de campo en la clave de registro, y el resto de los campos de registro se asignan a calificadores de columna.
HBase
Fuente de lotes que lee de una familia de columnas en una tabla de HBase.
Exportación por lotes de Hive
La exportación de Hive utilizará la consulta seleccionada como entrada para ejecutarla en la tabla de Hive y almacenar los resultados en la ubicación especificada.
Importación por lotes de Hive
Importa datos de un directorio o un archivo a una tabla de Hive mediante la instrucción de carga de Hive.
HTTP a HDFS
Acción para obtener datos de un endpoint HTTP externo y crear un archivo en HDFS.
Editor de alertas de Kafka
El editor de alertas de Kafka te permite publicar alertas en Kafka como objetos JSON.
Consumidor kafka
Fuente de lotes de Kafka que lee eventos de Apache Kafka en flujos de procesamiento por lotes.
Consumidor kafka
Fuente de streaming de Kafka que lee eventos de Apache Kafka en flujos de procesamiento de streaming.
Productor de Kafka
Sumidero de Kafka que te permite escribir eventos en CSV o JSON en Kafka.
Kudú
Complemento CDAP para ingerir datos en Apache Kudu. El complemento se puede configurar para los flujos de procesamiento por lotes y en tiempo real.
Kudú
Complemento CDAP para leer datos de la tabla de Apache Kudu.
Programa PySpark
Ejecuta el código de Spark proporcionado por el usuario en Python.
Repartición
Este complemento hace una nueva partición de un RDD de Spark.
Computación sobre Scala Spark
Ejecuta el código de Spark proporcionado por el usuario en Scala que transforma el RDD en RDD con acceso completo a todas las funciones de Spark.
Programa Scala Spark
Ejecuta el código de Spark proporcionado por el usuario en Scala.
Spark
Ejecuta código de Spark proporcionado por el usuario en Scala que funciona en un RDD o un framework de datos de entrada con acceso completo a todas las funciones de Spark.
Analizador de registros del servidor web
Analiza los registros de cualquier fuente de entrada para extraer información relevante, como URI, IP, navegador, dispositivo, código de estado HTTP y marca de tiempo.

APIs

Complementos para varias API.
Anaplan
Complemento de fuente para cargar datos de un modelo de Anaplan en un flujo de procesamiento de datos.
Anaplan
Complemento del sumidero para admitir la importación de datos de CDAP al servidor de Anaplan.
Función de Anaplan
Realiza una acción o un proceso que está predefinido en el modelo de Anaplan utilizado. Normalmente se usa para preparar la importación y la exportación de datos.
Facebook Ads
Lee los datos de Google Ads de la API de Facebook Insights en flujos de procesamiento por lotes.
GitHub
Lecturas de GitHub en flujos de procesamiento por lotes.
Varios informes de Google Ads
Lee todos los informes de Google Ads de una cuenta de Google Ads en flujos de procesamiento por lotes.
Informe único de Google Ads
Lee el tipo de informe especificado de las cuentas de Google Ads en flujos de procesamiento por lotes.
Lote de Google Analytics
Lee datos de flujos de procesamiento por lotes de Google Analytics 360.
Streaming de Google Analytics
Lee datos de flujos de procesamiento de streaming de Google Analytics 360.
Google Drive
Lee archivos del directorio de Google Drive especificado a través de la API de Google Drive.
Google Drive
El complemento de sumidero guarda los archivos del flujo de procesamiento en el directorio de Google Drive mediante la API de Google Drive.
Google Search Console
Lee datos de Google Search Console en flujos de procesamiento por lotes.
Hojas de cálculo de Google
Escribe hojas de cálculo en el directorio de Google Drive especificado.
Hojas de cálculo de Google
Lee hojas de cálculo del directorio de Google Drive especificado.
HTTP
Lee datos en formato JSON, XML, CSV, TSV, TEXT y BLOB de APIs HTTP/HTTPS en flujos de procesamiento por lotes.
HTTP
Complemento de sumidero para enviar los mensajes del flujo de procesamiento a un punto de conexión HTTP externo.
Retrollamada HTTP
Realiza una solicitud HTTP al final de la ejecución de un flujo de procesamiento.
Sondeador HTTP
Se trata de una fuente de streaming que obtiene datos de una URL determinada en un intervalo concreto y que envía los resultados al siguiente complemento.
Emisión de HTTP
Lee datos en formato JSON, XML, CSV, TSV, TEXT y BLOB de APIs HTTP/HTTPS en flujos de procesamiento en streaming
HTTP a HDFS
Acción para obtener datos de un endpoint HTTP externo y crear un archivo en HDFS.
HubSpot
Complemento para escribir datos en HubSpot CRM en flujos de procesamiento por lotes y de streaming.
HubSpot
Lee datos de HubSpot CRM en flujos de procesamiento de streaming.
HubSpot
Lee datos de HubSpot CRM en flujos de procesamiento por lotes.
Salesforce
En esta fuente se leen objetos de Salesforce como oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc. de Salesforce por lotes.
Salesforce
Esta fuente monitoriza las actualizaciones de los objetos de Salesforce. Los ejemplos de objetos son oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc.
Salesforce
Un sumidero por lotes que inserta objetos como oportunidades, contactos, cuentas, clientes potenciales, objetos personalizados, etc. en Salesforce.
Salesforce Marketing Cloud
Esta fuente realiza seguimientos de los objetos de Salesforce, como oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc.
Salesforce Marketing Cloud
Este sumidero inserta registros en una extensión de datos de Salesforce Marketing Cloud (SFMC) a través de una integración de servidor a servidor con la API de SFMC.
Varios objetos de Salesforce
Esta fuente lee varios objetos sObjects de Salesforce. Se debe utilizar junto con varios sumideros.
ServiceNow
Lee desde una o varias tablas de ServiceNow.
Speech‑to‑Text
Este complemento convierte Speech‐to‐Text en archivos de audio a texto.
Splunk
Lee datos de Splunk en flujos de procesamiento de streaming.
Splunk
Lee datos de Splunk en flujos de procesamiento por lotes.
Zendesk
Lee objetos como comentarios de artículos, comentarios de publicaciones, comentarios de entradas, grupos, organizaciones, puntuaciones de satisfacción, etiquetas, campos de entradas, métricas de entradas, eventos de métricas de entradas, entradas y usuarios de Zendesk.
Multiobjetos de Zendesk
Varias fuentes que leen varios objetos de Zendesk y los dirigen a destinos específicos. Se debe utilizar junto con un sumidero múltiple.
Zuora
Complemento para escribir datos en Zuora en flujos de procesamiento por lotes y de streaming.
Zuora
Lee datos de Zuora en flujos de procesamiento por lotes.

Avro

Complementos para Avro.
Archivo
Escribe en un sistema de archivos en varios formatos.
Archivo
Esta fuente se usa siempre que necesites leer desde un sistema de archivos distribuidos.
Cloud Storage
Escribe registros en uno o varios archivos de un directorio de Cloud Storage en diversos formatos, como CSV, Avro, Parquet y JSON.

AWS

Complementos disponibles para AWS.
Amazon S3
Esta fuente se usa siempre que necesites leer datos de Amazon S3.
Amazon S3
Este sumidero se usa para escribir en Amazon S3 en varios formatos.
Cliente de Amazon S3
La acción de cliente de Amazon S3 se usa para trabajar con segmentos y objetos de S3 antes o después de ejecutar un flujo de procesamiento.
Sumidero Kinesis
Sumidero de Kinesis que envía información al flujo de Amazon Kinesis especificado.
Fuente de Kinesis
Fuente de streaming de Spark que lee datos de flujos de AWS Kinesis.
Redshift a S3
La acción de Redshift a S3 ejecuta el comando de descarga en AWS para guardar los resultados de una consulta de Redshift en uno o varios archivos en Amazon S3.
S3 a Redshift
La acción de S3 a Redshift carga los datos de un segmento de AWS S3 en la tabla de AWS Redshift.

Limpieza

Complementos de limpieza.
Anular duplicado
Elimina los duplicados de registros mediante uno o varios campos, o bien con el registro en su conjunto. Además, permite elegir de forma lógica un registro de entre los duplicados según un campo de filtro. Las funciones lógicas admitidas son máximo, mínimo, primero y último.
Distinct
Elimina los duplicados de los registros de entrada para que todos los registros de salida sean distintos.
Filtro rápido
Filtra los mensajes en función de un criterio especificado.
Filtro de información personal identificable de Cloud DLP
Separa los registros sensibles en función de si coinciden con una plantilla definida por el usuario mediante las APIs de Cloud Data Loss Prevention (DLP).
Wrangler
Este complemento aplica directivas de transformación de datos generadas a través de una interfaz interactiva o manualmente en tus registros de datos.

Cloud Storage

Complementos disponibles para el almacenamiento en la nube.
Amazon S3
Esta fuente se usa siempre que necesites leer datos de Amazon S3.
Tienda de blobs de Azure
Fuente de lotes para usar el almacenamiento de blobs de Microsoft Azure como fuente.
Decompresión de Azure
El complemento de acción de descomprimir de Azure descomprime los archivos GZ de un contenedor en el servicio de blob de Azure Storage en otro contenedor.
Cloud Storage a Snowflake
Carga datos en Cloud Storage desde archivos externos o internos en área de stage en una tabla de Snowflake.
Cloud Storage
Este complemento de sumidero escribe registros en uno o varios archivos de un directorio de Cloud Storage en diversos formatos, como CSV, Avro, Parquet y JSON.
Cloud Storage
Este complemento lee objetos de una ruta en un segmento de Cloud Storage.
Configurador de argumentos de Cloud Storage
Lee datos de un archivo de Cloud Storage para obtener argumentos que se puedan definir en el flujo de procesamiento.
Eliminación de Cloud Storage
Este complemento elimina objetos de un segmento de Cloud Storage.
Copia de Cloud Storage
Este complemento copia objetos de un segmento de Cloud Storage en otro. Se puede copiar un único objeto o un directorio de objetos.
Creación de Cloud Storage
Este complemento crea objetos en un segmento de Cloud Storage.
Traslado de Cloud Storage
Este complemento mueve objetos de un segmento de Cloud Storage a otro. Se puede mover un solo objeto o un directorio de objetos.
Multiarchivo de Cloud Storage
Este complemento se utiliza junto con la fuente MultiTableDatabase para escribir registros de varias bases de datos en directorios independientes.
Marcador de archivo listo de Cloud Storage
Crea un archivo DONE (o CORRECTO) vacío en el segmento de Cloud Storage indicado al finalizar el proceso, o en caso de éxito o fallo, para orquestar los procesos dependientes.
Eliminación de Microsoft Azure
El complemento de acción de eliminación de Azure elimina un contenedor del servicio de blob de Azure Storage.
El copo de nieve en Cloud Storage
Descarga los datos de una tabla de Snowflake en una ubicación interna o externa de Cloud Storage (en área de stage).

Código

Complementos para ejecutar tu propio código. 
JavaScript
Ejecuta JavaScript proporcionado por los usuarios que transforma un registro en cero o en varios registros.
Programa PySpark
Ejecuta el código de Spark proporcionado por el usuario en Python.
Evaluador de Python
Ejecuta el código de Python proporcionado por el usuario para transformar los registros de entrada, que están disponibles como diccionario de Python.
Computación sobre Scala Spark
Ejecuta el código de Spark proporcionado por el usuario en Scala que transforma el RDD en RDD con acceso completo a todas las funciones de Spark.
Programa Scala Spark
Ejecuta el código de Spark proporcionado por el usuario en Scala.
Spark
Ejecuta código de Spark proporcionado por el usuario en Scala que funciona en un RDD o un framework de datos de entrada con acceso completo a todas las funciones de Spark.

Compresión

Complementos para comprimir.
Compresor
Comprime los campos configurados con distintos algoritmos de compresión, como SNAPPY, ZIP y GZIP.
Decompresión de Azure
La acción de descomprimir se usa para descomprimir archivos (.zip, .gz, .tar, .tar.gz, etc.) archivados o comprimidos antes de seguir procesándolos en un flujo de procesamiento.
Descompresor de campos
Descomprime los campos configurados mediante algoritmos de compresión, como SNAPPY, ZIP y GZIP.

Condicional

Los flujos de procesamiento también ofrecen complementos de flujo de control con las denominadas condiciones. Estos complementos te permiten dividir el flujo de procesamiento en dos ramas separadas, dependiendo de si el predicado de la condición especificada devuelve el valor verdadero o falso.
Condicional
Complemento de flujo de control que permite la ejecución condicional en flujos de procesamiento basados en expresiones.
Recopilador de errores
Recoge los errores emitidos desde la fase anterior y añade al mensaje un mensaje de error, un código y una fase.
Flujo de procesamiento tras fallos
Sumidero de lotes que provoca que el flujo de procesamiento falle inmediatamente después de recibir el primer registro.
Divisor de campo nulo
Este complemento envía los registros con un valor nulo para un campo concreto al puerto nulo, y los registros que no tengan un valor nulo al puerto no nulo.
Descomprimir
Dirige un registro a un puerto adecuado en función de la evaluación de una expresión sobre el valor de uno o varios campos.
Separador
El divisor de la unión se usa para dividir los datos mediante un esquema de unión, de modo que se pueda aplicar la lógica específica del tipo en un nivel inferior.

Flujo de control

Complementos para el flujo de control.
Función de Anaplan
Realiza una acción o un proceso que está predefinido en el modelo de Anaplan utilizado. Normalmente se usa para preparar la importación y la exportación de datos.
Ejecución de BigQuery
Ejecuta una consulta de SQL al principio o al final de un flujo de procesamiento.
Base de datos
Acción que ejecuta un comando de base de datos.
Consulta de base de datos
Ejecuta una consulta de base de datos al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de DB2
Acción que ejecuta un comando de DB2.
Decompresión de Azure
La acción de descomprimir se usa para descomprimir archivos (.zip, .gz, .tar, .tar.gz, etc.) archivados o comprimidos antes de seguir procesándolos en un flujo de procesamiento.
Comprobador de contenido de archivos
Este complemento de acción se puede usar para comprobar si un archivo está vacío o si su contenido coincide con un patrón determinado.
Eliminación de archivo
Elimina uno o varios archivos.
Traslado de archivo
Mueve uno o varios archivos.
Copia de FTP
Copia los archivos del servidor FTP en el destino especificado.
Copia en FTP
Copia los archivos de un destino concreto en el servidor FTP.
Eliminación de Cloud Storage
Este complemento elimina objetos de un segmento de Cloud Storage.
Copia de Cloud Storage
Este complemento copia objetos de un segmento de Cloud Storage en otro. Se puede copiar un único objeto o un directorio de objetos.
Creación de Cloud Storage
Este complemento crea objetos en un segmento de Cloud Storage.
Traslado de Cloud Storage
Este complemento mueve objetos de un segmento de Cloud Storage a otro. Se puede mover un solo objeto o un directorio de objetos.
HTTP a HDFS
Acción para obtener datos de un endpoint HTTP externo y crear un archivo en HDFS.
Ejecución de MariaDB
Acción que ejecuta un comando de MariaDB.
Ejecución de MySQL
Acción que ejecuta un comando de MySQL.
Ejecución de Netezza
Acción que ejecuta un comando de Netezza.
Ejecución de Oracle
Acción que ejecuta un comando de Oracle.
Exportación de Oracle
Un complemento de acción para exportar datos de Oracle de forma eficiente a un sistema de archivos mediante las herramientas de línea de comandos de Oracle.
Ejecución de PostgreSQL
Acción que ejecuta un comando de PostgreSQL.
Redshift a S3
La acción de Redshift a S3 ejecuta el comando de descarga en AWS para guardar los resultados de una consulta de Redshift en uno o varios archivos en Amazon S3.
Ejecutor de programas remotos
Establece una conexión SSH con un equipo remoto para ejecutar un comando en ese equipo.
S3 a Redshift
La acción de S3 a Redshift carga los datos de un segmento de AWS S3 en la tabla de AWS Redshift.
Copia de SFTP
La copia de SFTP permite copiar los archivos del directorio especificado en servidores SFTP en el destino especificado.
Eliminación de SFTP
Complemento de acción de CDAP para eliminar los archivos especificados de un servidor SFTP.
Colocar SFTP
El método SFTP permite subir archivos de un sistema de archivos (local o HDFS) al servidor FTP. Las regex de los archivos también se pueden usar para filtrar solo los archivos que interesan en un momento dado.
SQL de ejecución de Snowflake
Ejecuta una consulta de SQL específica en Snowflake.
Ejecución de SQL Server
Acción que ejecuta un comando de SQL Server.
Ejecución de Teradata
Acción que ejecuta un comando de Teradata.
Texto para compartir en Windows
Copia archivos de un equipo Microsoft Windows y los comparte con un sistema de archivos.

CRM

Complementos para plataformas de CRM como Salesforce.
HubSpot
Complemento para escribir datos en HubSpot CRM en flujos de procesamiento por lotes y de streaming.
HubSpot
Lee datos de HubSpot CRM en flujos de procesamiento de streaming.
HubSpot
Lee datos de HubSpot CRM en flujos de procesamiento por lotes.
Salesforce
En esta fuente se leen objetos de Salesforce como oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc. de Salesforce por lotes.
Salesforce
Un sumidero por lotes que inserta objetos como oportunidades, contactos, cuentas, clientes potenciales, objetos personalizados, etc. en Salesforce.
Salesforce
Esta fuente monitoriza las actualizaciones de los objetos de Salesforce. Los ejemplos de objetos son oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc.
Salesforce Marketing Cloud
Esta fuente realiza seguimientos de los objetos de Salesforce, como oportunidades, contactos, cuentas, clientes potenciales, cualquier objeto personalizado, etc.
Salesforce Marketing Cloud
Este sumidero inserta registros en una extensión de datos de Salesforce Marketing Cloud (SFMC) a través de una integración de servidor a servidor con la API de SFMC.
Varios objetos de Salesforce
Esta fuente lee varios objetos sObjects de Salesforce. Se debe utilizar junto con varios sumideros.

CSV

Complementos para CSV.
Formateador de CSV
Formatos introducidos en un registro CSV con formatos como DELIMITED, EXCEL, MYSQL, RFC4180 y TDF.
Analizador CSV
Analiza un registro CSV con el formato DEFAULT, EXCEL, MYSQL, RFC4180, Tab Delimitado, Pipe Delimitado en un registro estructurado.
Archivo
Escribe en un sistema de archivos en varios formatos.
Archivo
Esta fuente se usa siempre que necesites leer desde un sistema de archivos distribuidos.
Cloud Storage
Este complemento de sumidero escribe registros en uno o varios archivos de un directorio de Cloud Storage en diversos formatos, como CSV, Avro, Parquet y JSON.
Productor de Kafka
Sumidero de Kafka que te permite escribir eventos en CSV o JSON en Kafka.

Base de datos

Complementos para tus bases de datos.
Cloud Bigtable
Sumidero por lotes que escribe datos en Cloud Bigtable.
Cloud Bigtable
Esta fuente lee datos de Cloud Bigtable.
Base de datos
Acción que ejecuta un comando de base de datos.
Base de datos
Lee datos de una base de datos mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Base de datos
Escribe registros en una tabla de base de datos. Cada registro se escribirá en una fila de la tabla.
Configurador de argumentos de base de datos
Lee datos de una tabla de una base de datos relacional para obtener argumentos y configurar el flujo de procesamiento.
Consulta de base de datos
Ejecuta una consulta de base de datos al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
DB2
Lee datos de DB2 mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
DB2
Ejecuta una consulta de DB2 al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de DB2
Acción que ejecuta un comando de DB2.
DB2 de IBM
Escribe registros en una tabla de DB2. Cada registro se escribirá en una fila de la tabla.
MariaDB
Escribe registros en una tabla de MariaDB. Cada registro se escribirá en una fila de la tabla.
MariaDB
Lee datos de MariaDB mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
MariaDB
Ejecuta una consulta de MariaDB al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de MariaDB
Acción que ejecuta un comando de MariaDB.
Multitabla de base de datos
Lee varias tablas de una base de datos. Se utiliza con complementos de varios sumideros, como el sumidero múltiple de Cloud Storage y el de BigQuery, para cargar los datos de toda la base de datos en un solo flujo de procesamiento.
Consulta de MySQL
Ejecuta una consulta de MySQL al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
MySQL
Escribe registros en una tabla de MySQL. Cada registro se escribirá en una fila de la tabla.
MySQL
Lee datos de una instancia de MySQL mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Ejecución de MySQL
Acción que ejecuta un comando de MySQL.
Oracle
Lee datos de una tabla de Oracle mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Oracle
Escribe registros en una tabla de Oracle. Cada registro se escribirá en una fila de la tabla.
Oracle
Ejecuta una consulta de Oracle al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de Oracle
Acción que ejecuta un comando de Oracle.
Exportación de Oracle
Un complemento de acción para exportar datos de Oracle de forma eficiente a un sistema de archivos mediante las herramientas de línea de comandos de Oracle.
PostgreSQL
Lee datos de PostgreSQL mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
PostgreSQL
Escribe registros en una tabla PostgreSQL. Cada registro se escribirá en una fila de la tabla.
PostgreSQL
Ejecuta una consulta de PostgreSQL al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de PostgreSQL
Acción que ejecuta un comando de PostgreSQL.
Spanner
Este sumidero escribe en una tabla de Cloud Spanner.
Spanner
La fuente se lee a partir de una tabla de Cloud Spanner.
SQL Server
Escribe registros en una tabla de SQL Server. Cada registro se escribirá en una fila de la tabla.
SQL Server
Ejecuta una consulta de SQL Server al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
SQL Server
Lee datos de SQL Server mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Ejecución de SQL Server
Acción que ejecuta un comando de SQL Server.
DB2 de IBM
DB2 ejecuta una consulta de DB2 al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.

Almacén de datos

Complementos para tu almacén de datos.
BigQuery
Esta fuente lee todo el contenido de una tabla de BigQuery.
Establecedor de argumento de BigQuery
Lee datos de una tabla de BigQuery para obtener argumentos y configurar el flujo de procesamiento.
Ejecución de BigQuery
Este complemento ejecuta una consulta SQL de BigQuery.
Multitabla de BigQuery
Este sumidero escribe en varias tablas de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Tabla de BigQuery
Este sumidero escribe en una tabla de BigQuery. En primer lugar, los datos se escriben en una ubicación temporal de Cloud Storage y, desde ahí, se cargan en BigQuery.
Cloud Storage a Snowflake
Carga datos en Cloud Storage desde archivos externos o internos en área de stage en una tabla de Snowflake.
Exportación por lotes de Hive
La exportación de Hive utilizará la consulta seleccionada como entrada para ejecutarla en la tabla de Hive y almacenar los resultados en la ubicación especificada.
Importación por lotes de Hive
Importa datos de un directorio o un archivo a una tabla de Hive mediante la instrucción de carga de Hive.
Netezza
Escribe registros en una tabla de Netezza. Cada registro se escribirá en una fila de la tabla.
Netezza
Lee datos de Netezza mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
Netezza
Ejecuta una consulta de Netezza al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
Ejecución de Netezza
Acción que ejecuta un comando de Netezza.
Redshift a S3
La acción de Redshift a S3 ejecuta el comando de descarga en AWS para guardar los resultados de una consulta de Redshift en uno o varios archivos en Amazon S3.
S3 a Redshift
La acción de S3 a Redshift carga los datos de un segmento de AWS S3 en la tabla de AWS Redshift.
Computación Spark SCD2
Crea una representación de SCD2 de un registro agrupando los registros de fuente por la clave especificada y generando las fechas de inicio y finalización (caducidad) para el mismo.
Copos de nieve
Escribe datos en una tabla de copos de nieve en flujos de procesamiento por lotes.
Copos de nieve
Lee los datos de las tablas de copos de nieve en flujos de procesamiento por lotes.
SQL de ejecución de Snowflake
Ejecuta una consulta de SQL específica en Snowflake.
El copo de nieve en Cloud Storage
Descarga los datos de una tabla de Snowflake en una ubicación interna o externa de Cloud Storage (en área de stage).
TeraData
Escribe registros en una tabla de Teradata. Cada registro se escribirá en una fila de la tabla.
TeraData
Lee datos de Teradata mediante una consulta de SQL configurable. Genera un registro por cada fila devuelta por la consulta.
TeraData
Ejecuta una consulta de Teradata al final de un flujo de procesamiento. Se puede configurar para que se ejecute solo en caso de éxito, solo en caso de fallo o siempre al final del proceso.
TeraData
Acción que ejecuta un comando de Teradata.
Acción de exportación por lotes de Vertica
Exporta datos en bloque de una tabla de Vertica a un archivo.
Acción de importación en bloque de Vertica
El complemento de acción de importación en bloque de Vertica lee todos los archivos de un directorio determinado e importa el contenido en bloque a una tabla de Vertica.

DLP

Complementos para Cloud Data Loss Prevention (DLP)
Descifrado de Cloud DLP
Descifra datos sensibles que anteriormente se encriptaban con Cloud Data Loss Prevention (DLP) mediante una transformación reversible, como el encriptado con preservación de formato.
Filtro de información personal identificable de Cloud DLP
Separa los registros sensibles en función de si coinciden con una plantilla definida por el usuario mediante las APIs de Cloud Data Loss Prevention (DLP).
Ocultar datos de Cloud DLP
Oculta registros sensibles con Cloud Data Loss Prevention (DLP) al usar filtros predefinidos de DLP o una plantilla personalizada definida por el usuario.

Dinámico

Complementos dinámicos.
Configurador de argumentos
Realiza una solicitud HTTP para obtener los argumentos que se van a definir en el flujo de procesamiento.
Configurador de argumentos de base de datos
Lee datos de una tabla de una base de datos relacional para obtener argumentos y configurar el flujo de procesamiento.
Configurador de argumentos de Cloud Storage
Lee datos de un archivo de Cloud Storage para obtener argumentos que se puedan definir en el flujo de procesamiento.

Correo electrónico

Complementos para el correo electrónico.
Correo electrónico
Envía un correo electrónico al final de una ejecución de flujo de procesamiento.
Correo de SendGrid
Acción para enviar un correo electrónico al final de una ejecución de flujo de procesamiento.
SendGrid
Lee datos sobre campañas de marketing, analíticas de correo electrónico, mensajes de rebote e informes de spam de SendGrid.
SendGrid
Escribe datos en SendGrid en flujos de procesamiento por lotes y de streaming.

Archivo

Complementos de archivos.
Formateador de CSV
Formatos introducidos en un registro CSV con formatos como DELIMITED, EXCEL, MYSQL, RFC4180 y TDF.
Analizador CSV
Analiza un registro CSV con el formato DEFAULT, EXCEL, MYSQL, RFC4180, Tab Delimitado, Pipe Delimitado en un registro estructurado.
Archivo
Escribe en un sistema de archivos en varios formatos.
Archivo
Esta fuente se usa siempre que necesites leer desde un sistema de archivos distribuidos.
Archivo
Fuente de streaming de archivos que supervisa un directorio y emite contenido de cualquier archivo nuevo que se haya añadido al directorio.
Archivador de archivos
Este complemento de sumidero se añade a un archivo hasta que alcance un tamaño o un umbral basado en la edad.
Comprobador de contenido de archivos
Este complemento de acción se puede usar para comprobar si un archivo está vacío o si su contenido coincide con un patrón determinado.
Eliminación de archivo
Elimina uno o varios archivos.
Traslado de archivo
Mueve uno o varios archivos.
FTP
Fuente de lote para leer desde FTP (ftp://..) o SFTP (sftp://...).
Copia de FTP
Copia los archivos del servidor FTP en el destino especificado.
Copia en FTP
Copia los archivos de un destino concreto en el servidor FTP.
Extractor de PDF
Esta transformación utiliza la biblioteca de Box de PDF de Apache para extraer texto y metadatos de un archivo PDF.
Redshift a S3
La acción de Redshift a S3 ejecuta el comando de descarga en AWS para guardar los resultados de una consulta de Redshift en uno o varios archivos en Amazon S3.
Amazon S3
Este sumidero se usa para escribir en Amazon S3 en varios formatos.
S3 a Redshift
La acción de S3 a Redshift carga los datos de un segmento de AWS S3 en la tabla de AWS Redshift.
Copia de SFTP
La copia de SFTP permite copiar los archivos del directorio especificado en servidores SFTP en el destino especificado.
Eliminación de SFTP
Complemento de acción de CDAP para eliminar los archivos especificados de un servidor SFTP.
Colocar SFTP
El método SFTP permite subir archivos de un sistema de archivos (local o HDFS) al servidor FTP. Las regex de los archivos también se pueden usar para filtrar solo los archivos que interesan en un momento dado.

Filtro

Filtrar complementos.
Anular duplicado
Elimina los duplicados de registros mediante uno o varios campos, o bien con el registro en su conjunto. Además, permite elegir de forma lógica un registro de entre los duplicados según un campo de filtro. Las funciones lógicas admitidas son máximo, mínimo, primero y último.
Distinct
Elimina los duplicados de los registros de entrada para que todos los registros de salida sean distintos.
Filtro rápido
Filtra los mensajes en función de un criterio especificado.
Filtro de información personal identificable de Cloud DLP
Separa los registros sensibles en función de si coinciden con una plantilla definida por el usuario mediante las APIs de Cloud Data Loss Prevention (DLP).
Divisor de campo nulo
Este complemento envía los registros con un valor nulo para un campo concreto al puerto nulo, y los registros que no tengan un valor nulo al puerto no nulo.
Muestreo
Utiliza un conjunto de datos de muestra de gran tamaño para extraer registros aleatorios mediante muestreos sistemáticos o de embalses.
Los primeros N
Los primeros N devuelven los "n" registros principales del conjunto de entrada, según los criterios especificados en la configuración del complemento.

FTP

Complementos de FTP.
FTP
Fuente de lote para leer desde FTP (ftp://..) o SFTP (sftp://...).
Copia de FTP
Copia los archivos del servidor FTP en el destino especificado.
Copia en FTP
Copia los archivos de un destino concreto en el servidor FTP.
Copia de SFTP
La copia de SFTP permite copiar los archivos del directorio especificado en servidores SFTP en el destino especificado.
Eliminación de SFTP
Complemento de acción de CDAP para eliminar los archivos especificados de un servidor SFTP.
Colocar SFTP
El método SFTP permite subir archivos de un sistema de archivos (local o HDFS) al servidor FTP. Las regex de los archivos también se pueden usar para filtrar solo los archivos que interesan en un momento dado.
Complementos para Google Ads.
Varios informes de Google Ads
Lee todos los informes de Google Ads de una cuenta de Google Ads en flujos de procesamiento por lotes.
Informe único de Google Ads
Lee el tipo de informe especificado de las cuentas de Google Ads en flujos de procesamiento por lotes.
Google Search Console
Lee datos de Google Search Console en flujos de procesamiento por lotes.

Google Analytics 360

Complementos para Google Analytics 360.
Lote de Google Analytics
Lee datos de flujos de procesamiento por lotes de Google Analytics 360.
Streaming de Google Analytics
Lee datos de flujos de procesamiento de streaming de Google Analytics 360.

Google Workspace

Complementos para Google Workspace, incluidos Hojas de cálculo de Google y Google Drive.
Google Drive
Lee archivos del directorio de Google Drive especificado a través de la API de Google Drive.
Google Drive
El complemento de sumidero guarda los archivos del flujo de procesamiento en el directorio de Google Drive mediante la API de Google Drive.
Hojas de cálculo de Google
Lee hojas de cálculo del directorio de Google Drive especificado.
Hojas de cálculo de Google
Escribe hojas de cálculo en el directorio de Google Drive especificado.

Hadoop

Complementos para Hadoop.
HBase
Escribe registros en una tabla de HBase con una asignación de campo en la clave de registro, y el resto de los campos de registro se asignan a calificadores de columna.
HBase
Fuente de lotes que lee de una familia de columnas en una tabla de HBase.
Exportación por lotes de Hive
La exportación de Hive utilizará la consulta seleccionada como entrada para ejecutarla en la tabla de Hive y almacenar los resultados en la ubicación especificada.
Importación por lotes de Hive
Importa datos de un directorio o un archivo a una tabla de Hive mediante la instrucción de carga de Hive.
HTTP a HDFS
Acción para obtener datos de un endpoint HTTP externo y crear un archivo en HDFS.

HDFS

Complementos para HDFS.
XML Reader
El complemento XML Reader es un complemento de fuente que permite a los usuarios leer archivos XML almacenados en HDFS.
HTTP a HDFS
Acción para obtener datos de un endpoint HTTP externo y crear un archivo en HDFS.

HP

Complementos para HP.
Acción de exportación por lotes de Vertica
Exporta datos en bloque de una tabla de Vertica a un archivo.
Acción de importación en bloque de Vertica
El complemento de acción de importación en bloque de Vertica lee todos los archivos de un directorio determinado e importa el contenido en bloque a una tabla de Vertica.

HTTP

Complementos para HTTP.
Configurador de argumentos
Realiza una solicitud HTTP para obtener los argumentos que se van a definir en el flujo de procesamiento.