Multi File Transfer en BPMN: lógica de sincronización propia entre nubes y almacenamientos, con verificación de contenido

Lugar en la arquitectura

La transferencia se ejecuta como procesos BPMN versionados en MEF.DEV BPMN Low-code sobre Enablement & Monetization Platform, no como una aplicación independiente. Los procesos heredan la alineación de la plataforma con ODA: las funciones de API corresponden al rol de los componentes ODA, y Kubernetes con entrega GitOps es el entorno de operación. El contrato de cada proceso es su frontera tipada.

Componentes

• Lista de rutas Una lista de SharePoint con la ruta de origen, la ruta de destino, el modo de carga inicial y un indicador de actividad. La edita un administrador de SharePoint; la plataforma la lee al inicio de cada ciclo, la compara con la instantánea almacenada y escribe el estado.
• Proceso de ciclo transfer_files atiende un drive durante un ciclo.
• Proceso de archivo transfer_file mueve un archivo en cuatro operaciones tipadas.
• Plugin de backend Ejecuta las operaciones contra Microsoft Graph y SFTPGo.
• Worker de tareas Retoma el trabajo inconcluso tras un fallo.

Contratos

• DriveWorkModel Entrada de un ciclo: clave del drive, posición almacenada (DeltaLink), rutas que atender y memoria de rutas.
• FileTransferModel Entrada de una transferencia: operationId, transporte y ruta de origen, transporte y ruta de destino, nombre final.
• OperationResult Estado con código de error, identificador de correlación y retryAfterSeconds. Un rechazo como FinalNameConflict se devuelve como resultado, y quien invoca decide según el estado.
• Resultados del ciclo COMMITTED, NOT_COMMITTED, NO_DELTA_LINK y, en modo de depuración, PLANNED_ONLY.
• Credenciales El valor de un access token no cruza la frontera BPMN: la credencial se aplica al contexto de la conexión. La aplicación utiliza Sites.Selected con consentimiento de administrador.

Flujo de un ciclo

1. Una notificación solo señala un cambio. El ciclo lee los cambios mediante Microsoft Graph página por página desde la posición almacenada.
2. Un cambio posterior de un archivo reemplaza al anterior, de modo que un archivo se transfiere como máximo una vez por ruta en cada ciclo.
3. El ciclo planifica una transferencia por archivo y ruta y llama a transfer_file para cada una, una tras otra.
4. Cada transferencia resuelve el destino, lee el origen, carga en una ubicación temporal y finaliza con el nombre definitivo. El archivo solo se vuelve visible en el destino en ese último paso.
5. La nueva posición, junto con la memoria de rutas, se confirma solo cuando todas las transferencias se han completado; de lo contrario, el ciclo siguiente vuelve a empezar desde la posición anterior.

Recuperación

• El estado de cada llamada se guarda: tras un reinicio, los archivos completados no se transfieren de nuevo y el paso interrumpido se ejecuta otra vez desde el principio.
• Un worker retoma la tarea inconclusa y continúa la misma instancia principal; un segundo host asume el trabajo cuando el primero se detiene.
• Un reinicio no reanuda los bytes desde un desplazamiento, y una operación posterior al último estado guardado puede repetirse.

Puntos de integración

• Microsoft 365 HTTPS saliente hacia Microsoft Graph a través de un forward proxy con allowlist; un endpoint HTTPS entrante en el reverse proxy de la DMZ (Demilitarized Zone) para las notificaciones.
• SFTPGo Para cada ruta, el administrador de SFTPGo define las zonas staging, published y quarantine, una cuenta técnica, una regla de evento de carga hacia el broker de mensajes y una verificación ICAP como condición de publicación. Los socios solo ven published.
• Plataforma Un broker de mensajes, una base de datos para el registro de transferencias, los cursores y las suscripciones, y un planificador para la renovación de suscripciones y un ciclo de control diario.

Personas al mando

El administrador de SharePoint es responsable de las rutas y las pausa o reanuda. El proceso reintenta automáticamente las transferencias fallidas, y un servicio externo controla la cuarentena mediante ICAP.

Límites

• Una ruta es unidireccional; el sentido opuesto es una ruta aparte con carpetas aparte.
• Las eliminaciones no se propagan, y un archivo renombrado se considera nuevo.
• Los permisos, el historial de versiones y los metadatos de SharePoint no se transfieren.
• No se conserva el orden entre archivos; el modo de carga inicial se fija al crear la ruta.

Alcance de la solución

El alcance de la cuarentena y de los ciclos de control descritos arriba se acuerda en el proyecto.

Detalle técnico en platform.mef.dev →