Flujos de datos conectados
01El nombre del conector es el inicio del diseño.
Conecta los sistemas existentes mediante un modelo compartido de orquestación y procesamiento. Flower integra planificación, transformación, validación, recuperación y evidencias operativas para gestionar el intercambio como un flujo coherente.
Conecta las fuentes de datos
Determina cómo interactúan listado, paginación, snapshots, cursores de cambio y mutaciones concurrentes. La ruta necesita una posición duradera y una regla para objetos o filas creados, cambiados, renombrados o eliminados durante el recorrido.
Entrega a tus destinos
Verifica atomicidad, éxito parcial, overwrite o upsert, retraso de visibilidad e idempotencia en destino. Define qué confirmación cierra la unidad y qué debe reconciliarse antes de repetir una escritura con timeout.
Diseña identidad y rotación de secretos
Prueba mínimo privilegio, rotación de credenciales y certificados, requisitos de proxy o red privada y caducidad durante trabajos largos. Decide cómo obtienen y renuevan secretos los runtimes desconectados sin incrustarlos en flujos ni bloquear la recuperación.
Define el contrato de datos
Especifica evolución de esquema, precisión de tipos, nulos, zonas horarias, codificación, orden y conversión de formato. Decide qué cambios son compatibles, cuáles requieren cuarentena y cómo acompaña la evidencia de validación a los datos transformados.
Ubica procesamiento y rutas de red
Registra dónde cruzan los bytes regiones, redes públicas, gateways, proxies o límites de egress y dónde se ejecutan filtrado, agregación, compresión y cifrado. Incluye residencia, latencia, aislamiento de fallos y operación sin conexión.
Alinea la semántica de ciclo de vida
Mapea borrado, renombrado, archivo, retención, bloqueo legal, inmutabilidad, sustitución en destino y limpieza. El diseño no está completo hasta alinear los ciclos de vida y la evidencia previa a acciones destructivas.
Transporta la evidencia de recuperación
Conecta identidad de origen, checkpoint, transformación, validación, resultado en destino, intentos, reconciliación, cuarentena y acción final en una traza. Las alertas deben mostrar esa cadena sin correlacionar logs inconexos.
Prueba rendimiento y coste total
Mide tamaños reales, lotes de filas, concurrencia, cuotas API, transacciones, compresión, recuperación de cola y efecto de archivos pequeños. Valora juntos cómputo, almacenamiento, solicitudes, egress, gateways, monitorización, soporte y trabajo operativo.
Conecta el entorno que ya tienes
02Almacenamiento y transferencia
Usa almacenamiento de objetos cloud, HDFS, recursos SMB, servicios de archivos, protocolos seguros, archivos locales y API especializadas como orígenes o destinos. Cada ruta puede heredar planificación, reintentos, reconciliación, validación, linaje, políticas de ciclo de vida y alertas proactivas, sin reconstruir esos controles para cada conector.
Amplía las rutas a MinIO, Backblaze B2, Huawei Cloud OBS, Tencent Cloud COS, Volcano Engine TOS y UPYUN, o mueve archivos mediante Koofr y pCloud. Los adaptadores nativos integran almacenamiento privado y regional en el mismo flujo declarativo, con orquestación, procesamiento y visibilidad operativa compartidos.
Incorpora archivos de equipos a flujos gobernados con Box, Egnyte, Files.com, ShareFile y Seafile. MongoDB GridFS añade almacenamiento de archivos en streaming, metadatos nativos y revisiones conservadas, conectando las entregas documentales al mismo modelo de orquestación y procesamiento.
Reutiliza carpetas y servicios de archivos de equipos como orígenes y destinos. Flower integra planificación, procesamiento de registros, comprobaciones de entrega y políticas de ciclo de vida para automatizar el trabajo recurrente con las herramientas de colaboración existentes.
Amazon S3
Almacenamiento de objetos
Más información →
Azure Blob
Almacenamiento de objetos
Más información →Azure Files
Almacenamiento de archivos
Azure Data Lake
Almacenamiento de lago de datos
Google Cloud Storage
Almacenamiento de objetos
Más información →
Oracle Cloud
Almacenamiento de objetos
Alibaba OSS
Almacenamiento de objetos
OpenStack Swift
Almacenamiento de objetos
MinIO
Almacenamiento de objetos
Backblaze B2
Almacenamiento de objetos
Huawei Cloud OBS
Almacenamiento de objetos
Tencent Cloud COS
Almacenamiento de objetos
Volcano Engine TOS
Almacenamiento de objetos
UPYUN
Almacenamiento de objetos
Apache Hadoop HDFS
Sistema de archivos distribuido
Google Drive
Unidad cloud
Dropbox
Unidad cloud
Koofr
Unidad cloud
pCloud
Unidad cloud
Microsoft OneDrive
Unidad cloud
SharePoint libraries
Biblioteca de documentos
Box
Archivos y carpetas nativos
Egnyte
Archivos y carpetas nativos
Files.com
Archivos y carpetas nativos
ShareFile
Archivos y carpetas nativos
Seafile
Biblioteca de documentos
MongoDB GridFS
Almacenamiento de archivos en MongoDB
Databricks Volumes
Almacenamiento lakehouse
App Store Connect
API de informes
SFTP / SSH
Transferencia segura
Más información →FTP / FTPS
Transferencia de archivos
WebDAV
Almacenamiento web
HTTP / HTTPS
Transferencia web
SMB 2 / 3
Recurso compartido de red
Archivos locales
Almacenamiento del dispositivo
IMAP
Fuente de correo
03Bases y motores de consulta
Conecta Snowflake, bases transaccionales, motores analíticos, almacenes, lakehouses, bases distribuidas y protocolos SQL con un modelo común de orquestación. Flower permite lecturas, escrituras y transacciones explícitas gobernadas, con controles de integridad y evidencias operativas durante el flujo.
Incorpora los datos SQL operativos al mismo flujo gobernado. Flower ofrece adaptadores nativos para Firebird y Huawei GaussDB, conecta MariaDB mediante su adaptador MySQL y CockroachDB mediante compatibilidad PostgreSQL. Estas conexiones admiten lecturas, escrituras y transacciones explícitas; el cliente Firebird no requiere instalar por separado una biblioteca cliente nativa.
Combina extracción SQL, carga y validación en una ruta declarativa. Aplica planificación, gestión de credenciales y supervisión comunes a sistemas operativos y analíticos, manteniendo los flujos alineados con tu arquitectura de bases de datos.
Para entornos estandarizados en ODBC, Flower ofrece acceso adaptado al motor de su base de estado de aplicación, además de conectividad de datos ODBC. Los perfiles SQL cubren PostgreSQL, GaussDB, CockroachDB, MySQL, Microsoft SQL Server y SQLite, aprovechando las bases y la infraestructura de controladores existentes.
PostgreSQL
Base de datos SQL
Más información →
MySQL
Base de datos SQL
Más información →
Microsoft SQL Server
Base de datos SQL
Más información →Oracle Database
Base de datos SQL
Más información →
SQLite
Base embebida
ClickHouse
Base analítica
Databricks SQL
Almacenamiento lakehouse
Snowflake
Plataforma de datos cloud
SAP HANA
Base de datos SQL
Cloud Spanner
Base distribuida
Trino
Motor de consulta
Presto
Motor de consulta
Exasol
Base analítica
Vertica
Base analítica
IBM Netezza
Almacén de datos
Arrow Flight SQL
Protocolo de consulta
ODBC / Avatica
Acceso SQL genérico
Firebird
Base de datos SQL
Huawei GaussDB
Base de datos SQL
MariaDB
SQL mediante compatibilidad MySQL
CockroachDB
SQL distribuido mediante PostgreSQL
04Cachés compartidas
Reutiliza estado intermedio entre componentes Flower con servicios clave-valor gestionados, colecciones persistentes o mapas distribuidos. Las integraciones de caché ofrecen organización de claves, caducidad y tiempos adaptados al motor dentro del mismo flujo gobernado.
Comparte estado reutilizable entre componentes con caducidad y organización de claves adaptadas al motor. Las concesiones etcd, colecciones MongoDB y elementos DynamoDB gestionan el ciclo de vida de las cachés dentro del flujo, con configuración coherente y visibilidad operativa de Flower.
Redis, Valkey y Dragonfly comparten el adaptador Redis de Flower para endpoints RESP2/RESP3, con caducidad de claves y operaciones por prefijo. Reutiliza un modelo clave-valor conocido e integra el estado de la caché en la configuración declarativa del flujo.
etcd
Caché clave-valor distribuida
MongoDB
Caché persistente sobre colecciones
Amazon DynamoDB
Caché sobre tablas gestionadas
Couchbase
Caché persistente sobre colecciones
Aerospike
Caché clave-valor distribuida
Hazelcast
Caché sobre mapas distribuidos
Oracle Coherence
Caché con nombre mediante gRPC
Infinispan
Caché distribuida mediante REST
TiKV
Caché RawKV distribuida
Redis
Caché clave-valor distribuida
Valkey
Caché mediante compatibilidad Redis
Dragonfly
Caché mediante compatibilidad Redis
05IA y clasificación local
Enriquece y clasifica registros dentro del flujo. Flower conecta OpenAI y Anthropic Claude para transformaciones estructuradas, ofrece inferencia local opcional GGUF con llama.cpp y usa ONNX para clasificación local de texto y zero-shot. Elige dónde procesar según la confidencialidad, el hardware y los costes.
Controla qué campos llegan a los modelos externos y define el esquema de salida en la configuración. Flower coordina las solicitudes, conserva el orden de los registros y aplica tus políticas, integrando el enriquecimiento IA en la misma ruta gobernada que la validación, transformación y entrega.
Los filtros semánticos usan OpenAI, Claude o modelos GGUF locales para seleccionar registros con criterios expresados en lenguaje natural. Conserva o excluye coincidencias manteniendo campos, valores y orden. La selección de campos, las políticas de procesamiento y las métricas integran estas decisiones en un flujo observable y configurable.
Clasifica texto localmente con modelos ONNX y añade etiquetas y puntuaciones a los registros, o usa categorías para guiar los filtros. Elige modelo y tokenizer adecuados para tus idiomas y datos. Flower ejecuta la clasificación sin una biblioteca compartida ONNX Runtime, cerca de los datos.
Elige inferencia local opcional GGUF con llama.cpp para procesar modelos de lenguaje en tu infraestructura. Flower carga el modelo bajo demanda y ejecuta la inferencia dentro del runtime, acercando transformaciones y filtros semánticos a los datos con control directo del modelo y la ejecución.
Reconoce probables nombres personales localmente mediante un diccionario integrado. Etiqueta o filtra registros dentro del flujo con umbrales de puntuación y políticas configurables. El procesamiento permanece en Flower, sin llamadas a modelos externos ni descargas de modelos.
OpenAI
Respuestas estructuradas de modelos
Anthropic Claude
Respuestas estructuradas de modelos
llama.cpp / GGUF
Inferencia local opcional de modelos de lenguaje
ONNX
Clasificación local de texto y zero-shot
Detección de nombres personales
Clasificación local basada en diccionario
06Secretos y certificados
Reúne secretos y certificados de bóvedas cloud, almacenes de clúster, archivos cifrados o directorios locales en una configuración unificada. Flower prepara una instantánea coherente de solo lectura antes de iniciar los componentes dependientes, integrando la configuración segura en el ciclo de vida del flujo.
Azure Key Vault
Secretos y certificados cloud
Google Cloud Secret Manager
Secretos y certificados cloud
AWS Secrets Manager + KMS
Gestor de secretos y servicio de claves
AWS Systems Manager Parameter Store
Almacén gestionado de parámetros
Oracle Cloud Infrastructure Vault
Bóveda cloud y secretos
HashiCorp Vault / OpenBao
Bóveda empresarial de secretos
Alibaba Cloud KMS Secrets Manager
Secretos y certificados cloud
Huawei Cloud CSMS
Secretos y certificados cloud
IBM Cloud Secrets Manager
Secretos y certificados cloud
Kubernetes Secrets
Almacén de secretos del clúster
SOPS encrypted files
Archivos de configuración cifrados
Archivos locales
Fuente local restringida de secretos
07Runtimes de proceso opcionales
Los flujos estándar de Flower son declarativos y no requieren programación. Los runtimes opcionales JavaScript, Lua, WebAssembly, Starlark y AWK añaden procesamiento personalizado dentro del flujo, sin un servicio de cómputo externo. Utiliza Starlark para reglas deterministas y AWK para registros de texto, CSV y TSV en movimiento.
JavaScript
Procesamiento JavaScript
Lua
Runtime Lua aislado
WebAssembly
Módulos WebAssembly aislados
Starlark
Procesamiento de reglas deterministas
AWK
Procesamiento de texto, CSV y TSV
08Formatos en movimiento
Decodifica, transforma, agrega, valida, cifra, comprime, transcodifica y vuelve a codificar formatos operativos y analíticos mientras se mueven entre endpoints. Procesa los datos en movimiento para entregar la forma requerida sin una cadena innecesaria de servicios externos.
Integra las entregas de hojas de cálculo en el mismo flujo que archivos y bases. Además de Excel, Flower lee OpenDocument Spreadsheet (ODS) y crea libros ODS 1.3. Selecciona hoja e intervalo, mapea columnas y valida encabezados, y convierte los registros a CSV, JSON, Parquet u otro destino compatible. El procesamiento se ejecuta directamente en Flower, sin aplicaciones ofimáticas.
Para fórmulas ODS, elige resultados guardados, expresiones originales o recálculo OpenFormula según el flujo. Integra valores y resultados de fórmulas en validación, transformación y entrega analítica con el mismo modelo de procesamiento declarativo.
Protege los intercambios de hojas de cálculo con cifrado ODS por contraseña. Flower admite AES-CBC y AES-GCM en entrada y salida, integrando la protección de datos en el mismo flujo declarativo que el procesamiento y la entrega.
CSV
Formato en movimiento
JSON
Formato en movimiento
Avro
Formato en movimiento
Parquet
Formato en movimiento
Excel
Formato en movimiento
ODS
Hojas de cálculo OpenDocument
XML
Formato en movimiento
CBOR
Formato en movimiento
MessagePack
Formato en movimiento
Fixed-width
Formato en movimiento