Almacenamiento y Transferencia de Archivos

Azure Storage Blob Service

Descripción: el componente Azure Storage Blob Service almacena y recupera blobs (objeto binario grande) del servicio Azure Storage Blob utilizando las APIs de Azure v12.
Ejemplo
- El flujo comienza con una solicitud POST al endpoint /hello.
- El componente azure-storage-blob se utiliza para conectarse al contenedor myblobcontainer en la cuenta camelstorageaccount01.
- Parámetros:
  - credentialType: "SHARED_ACCOUNT_KEY": especifica que la autenticación usará la clave de cuenta compartida.
  - operation: "listBlobs": define que la operación realizada será listar los blobs presentes en el contenedor.
  - accessKey: "{{AWS_ACCESS_KEY}}": especifica la clave de acceso para autenticación, referenciada en una variable.
- Después de listar los blobs, el flujo registra información en el log con el identificador myLogger.

Script

Diagrama

- from:
    uri: "rest:post:/hello"
    steps:
    - to:
        uri: "azure-storage-blob://camelstorageaccount01/myblobcontainer"
        parameters:
          credentialType: "SHARED_ACCOUNT_KEY"
          operation: "listBlobs"
          accessKey: "{{AWS_ACCESS_KEY}}"
    - to:
        uri: "log:myLogger"

AWS S3 Storage Service

Descripción: el componente AWS S3 Storage Service permite que interactúe con el servicio Amazon S3 (Simple Storage Service) de AWS y maneje datos en buckets S3 directamente a través de las rutas de integración.
Ejemplo
- El flujo comienza con una solicitud GET al endpoint /file/retrieve.
- El conector recupera un archivo del bucket S3.
  - uri: Define el bucket (nombre o ARN).
  - Los parámetros incluyen:
    
    fileName: define la ruta del archivo en el bucket (por ejemplo, path/to/myfile.txt).
    
    accessKey y secretKey: son credenciales de autenticación para acceder al bucket, referenciadas como variables de entorno.
- Después de que el archivo se recupere con éxito, el contenido del archivo se registra en el log.

Script

Diagrama

- from:
    uri: "rest:get:/file/retrieve"
    steps:
      - to:
          uri: "aws2-s3:bucketNameOrArn"
          parameters:
            fileName: "path/to/myfile.txt"
            accessKey: "{{ACCESS_KEY}}"
            secretKey: "{{SECRET_KEY}}"
      - log:
          message: "File retrieved successfully: ${body}"

FTP/FTPS

Descripción: el componente FTP proporciona acceso a sistemas de archivos remotos a través de los protocolos FTP y SFTP. Funcionamiento solo en modo pasivo.

El FTPS es una versión segura de FTP, que agrega soporte para SSL/TLS para cifrar la conexión.

Ejemplo
- El flujo comienza con la descarga de un archivo desde un servidor FTP. El servidor se especifica mediante la variable ftp_host.
- Transforma el contenido del archivo reemplazando los caracteres acentuados 'ã', 'â', 'á', 'à' y 'ä' por 'a'.
- Luego, realiza la carga del archivo modificado en el mismo o en otro directorio en el servidor FTP.

Script

Diagrama

- from:
    id: ftp-input
    uri: "ftp:{{ftp_host}}/download"
    parameters:
      fileName: "{{ftp_filename_extension_input}}"
      password: "{{ftp_password}}"
      username: "{{ftp_username}}"
      delay: 10000
      passiveMode: true
    steps:
      - transform:
          simple: ${bodyAs(String).replaceAll('[ãâáàä]', 'a')}
      - to:
          id: ftp-output
          uri: "ftp:{{ftp_host}}/upload"
          parameters:
            fileName: "{{ftp_filename_extension_output}}"
            password: "{{ftp_password}}"
            username: "{{ftp_username}}"
            passiveMode: true

Google Storage

Descripción: el componente Google Storage permite la integración con el servicio Google Cloud Storage, facilitando el almacenamiento y la recuperación de objetos en buckets de Google Cloud. Como conector, puede configurarse para realizar upload de archivos, listar objetos y eliminar elementos de buckets. La integración ofrece soporte para el envío de diferentes tipos de archivos, además de permitir la personalización de encabezados, control de sobrescritura y manejo de errores.
Ejemplo
- El flujo recibe una solicitud GET.
- Se conecta a Google Cloud Storage usando las credenciales de la cuenta de servicio y elimina el objeto especificado en el bucket.
- Luego, registra en el log que el objeto fue eliminado.

Script

Diagrama

- from:
    uri: rest:get:/simple
    steps:
      - to:
          uri: google-storage:my bucket
          parameters:
            serviceAccountKey: my account key
            objectName: object name
            operation: deleteObject
      - log:
          message: object deleted

SFTP

Descripción: el componente SFTP proporciona acceso a sistemas de archivos remotos a través de los protocolos FTP y SFTP. Funciona solo en modo pasivo.
Ejemplo
- El flujo del ejemplo está configurado para ser activado por un programador Quartz, que se dispara cada minuto.
- Cuando se activa el gatillo, el cuerpo del mensaje se define como Hello World.
- El flujo luego envía este mensaje como un archivo llamado helloworld.txt a un servidor SFTP en la dirección demo.wftpserver.com, en el puerto 2222, en el directorio /upload.

Script

Diagrama

- from:
    uri: "quartz://ipaas/trigger"
    parameters:
      cron: "* * * * *"
    steps:
    - setBody:
        constant: "Hello World"
    - to:
        uri: "sftp://demo.wftpserver.com:2222/upload"
        parameters:
          username: "demo"
          password: "demo"
          fileName: "helloworld.txt"
          passiveMode: true

SMB

Descripción: el componente SMB permite integrar el flujo con directorios compartidos a través del protocolo SMB/CIFS, posibilitando el envío de archivos directamente a un servidor remoto.

Es posible configurar:
- Ruta del servidor: dirección completa del recurso compartido SMB, por ejemplo: smb://server/share/folder. (pestaña Common)
- Credenciales de autenticación: información de acceso, como usuario, contraseña y, cuando sea aplicable, dominio. (pestaña Security)
- Opciones adicionales: parámetros para controlar el comportamiento del envío, como sobrescribir archivos existentes, crear directorios ausentes y definir permisos de acceso.
  
  La integración soporta el envío de múltiples archivos en una única ejecución y permite configurar parámetros de control y encabezados de mensaje para personalizar el procesamiento y el enrutamiento de los archivos enviados.
Sintaxis de la URI: smb:hostname:port/shareName

Campos principales

Parámetros de ruta (path parameters)

Nombre Descripción Por defecto Tipo

Nombre	Descripción	Por defecto	Tipo
`hostname`	(obligatorio) El nombre del host o dirección IP del recurso compartido.	-	String
`port`	El número de puerto del recurso compartido.	445	int
`shareName`	(obligatorio) El nombre del directorio compartido.	-	String

hostname

(obligatorio) El nombre del host o dirección IP del recurso compartido.

String

port

El número de puerto del recurso compartido.

445

int

shareName

(obligatorio) El nombre del directorio compartido.

String

Parámetros de consulta (query parameters)

Nombre Descripción Por defecto Tipo

Nombre	Descripción	Por defecto	Tipo
`password`	(security) La contraseña para acceder al recurso compartido.	-	String
`username`	(security) El nombre de usuario necesario para acceder al recurso compartido.	-	String

password

(security) La contraseña para acceder al recurso compartido.

String

username

(security) El nombre de usuario necesario para acceder al recurso compartido.

String

El parámetro de consulta Path, de la pestaña Common, es un campo opcional desde la versión 4.8.0 de Apache Camel.

Ejemplo
- El flujo es activado por una solicitud HTTP GET en el endpoint /test.
- El cuerpo (setBody) del mensaje se define como el texto It worked!.
- El encabezado (setHeader) CamelFileName se establece como poc-smb.txt, indicando el nombre del archivo que se creará/enviará.
- El contenido se envía a un recurso compartido SMB (Windows File Share) en la dirección server-example, puerto 445, en el recurso compartido myshare. Los parámetros son las credenciales username y password.
- Después del envío, se registra un log con el mensaje Concluído con sucesso.
  
  En resumen, el flujo recibe una solicitud GET, crea un archivo llamado poc-smb.txt con el contenido "It worked!" en un recurso compartido SMB remoto, y registra un log al final.

Script

Diagrama

- from:
    uri: rest:get:/test
    steps:
      - setBody:
          constant: It worked!
      - setHeader:
          name: CamelFileName
          constant: poc-smb.txt
      - to:
          uri: "smb:server-example:445/myshare"
          parameters:
            username: yourusername
            password: yourpassword
      - log:
          message: "Concluído com sucesso"

Thanks for your feedback!

EDIT

Share your suggestions with us!
Click here and then [+ Submit idea]