> Mejora continua de procesos > Procesamiento de pagos > SWIFT > Template de datos

Su Template de datos para el procesamiento de pagos

SWIFT

Atributos del procesamiento de pagos(19) Actividades del procesamiento de pagos(12) Guías de extracción(3)

Su Template de datos para el procesamiento de pagos

Este Template proporciona la base estructural para mapear los flujos de trabajo de sus transacciones SWIFT, desde el inicio hasta la liquidación final. Detalla los componentes de datos y los hitos operativos necesarios para obtener una visión completa del ciclo de vida de los pagos. Con esta guía, podrá preparar sus datos para descubrir ineficiencias ocultas y reducir los riesgos de incumplimiento.

Atributos recomendados para analizar las transacciones en detalle
Actividades e hitos clave del proceso SWIFT
Orientación técnica para extraer datos financieros

¿Es nuevo en los registros de eventos? Aprenda a crear un Registro de eventos para Process Mining.

Descargar Template

Atributos del procesamiento de pagos

Estos son los campos de datos recomendados para incluir en su Registro de eventos y analizar de forma exhaustiva el ciclo de vida de sus transacciones SWIFT.

5 Obligatorio 9 Recomendado 5 Opcional

	Nombre	Descripción
	ID de transacción de pago PaymentTransactionId	Identificador único del caso de pago de principio a fin.
Descripción Este atributo funciona como clave central del caso para Process Mining. Agrupa todas las actividades relacionadas con una instrucción de pago, desde la solicitud inicial hasta la validación, la transmisión SWIFT y la liquidación final. En el contexto de SWIFT, suele corresponder al número de referencia de la transacción (TRN) o a la referencia única de transacción de principio a fin (UETR), para mantener la continuidad entre los sistemas bancarios. Se utiliza para reconstruir la ruta de cada instancia del proceso y es esencial para analizar todas las variantes y calcular los tiempos de ciclo. Por qué es importante La identificación única es la base de Process Mining, ya que permite reunir eventos dispersos en una visión coherente del proceso. Dónde obtenerlo Campo 20 (TRN) o campo 121 (UETR) de SWIFT en los encabezados de los mensajes. Ejemplos TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	Marca de tiempo del evento EventTimestamp	Fecha y hora exactas en que tuvo lugar la actividad.
Descripción Este atributo registra el momento exacto en que se produjo un evento. Se utiliza para ordenar las actividades cronológicamente y calcular todas las métricas basadas en la duración, como los tiempos de entrega, los tiempos de ciclo y el volumen de procesamiento. Las marcas de tiempo precisas son fundamentales para analizar el rendimiento respecto a los horarios de corte de la red e identificar cuellos de botella en la cadena de aprobación. Por qué es importante Las marcas de tiempo son la base de todos los análisis temporales y las métricas de rendimiento de Process Mining. Dónde obtenerlo Registros de auditoría del sistema, marcas de tiempo de creación de mensajes o tiempos de transacción de la base de datos. Ejemplos 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	Nombre de la actividad ActivityName	Nombre del paso del proceso o del evento que tuvo lugar.
Descripción Este atributo describe la acción concreta o el cambio de estado registrado en el registro del sistema. Algunos ejemplos son Pago solicitado, Control de sanciones superado o Confirmación ACK de SWIFT recibida. Es la dimensión principal de los mapas de procesos: define los nodos de la visualización y permite a los analistas comprender la secuencia de operaciones realizadas en un pago. Por qué es importante Define qué ocurre en el proceso y permite visualizar el flujo y sus variantes. Dónde obtenerlo Registros de transacciones, registros de auditoría o datos derivados de los tipos de mensaje (por ejemplo, MT103 enviado). Ejemplos Solicitud de pago creadaInstrucción de pago enviadaConfirmación ACK de SWIFT recibidaPago aprobado
	Sistema de origen SourceSystem	Nombre del sistema del que proceden los datos del evento.
Descripción Identifica el software o la plataforma que generó el registro de eventos. En un proceso de pago, puede ser el sistema bancario central, el gateway de pagos o directamente la interfaz SWIFT. Este atributo ayuda a verificar el linaje de los datos y a depurar problemas al combinar datos de distintas aplicaciones bancarias. Por qué es importante Aporta contexto sobre el origen de los datos, algo esencial para aplicar Process Mining en varios sistemas. Dónde obtenerlo Valor codificado durante el proceso ETL o extraído de los identificadores del sistema. Ejemplos SWIFT Alliance AccessSistema bancario centralMotor de pagosFiltro de sanciones
	Última actualización de los datos LastDataUpdate	Marca de tiempo de la última extracción o actualización del registro.
Descripción Indica cuándo se cargaron por última vez los datos en la herramienta de Process Mining. Es fundamental para determinar si los datos están actualizados y garantizar que los Dashboards reflejen el estado más reciente de las operaciones de pago. Permite que los usuarios confíen en los datos al mostrar con transparencia la latencia de la canalización de informes. Por qué es importante Ayuda a los usuarios a comprender la actualidad y fiabilidad de los datos presentados. Dónde obtenerlo Marca de tiempo de ejecución del proceso ETL. Ejemplos 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	BIC del beneficiario BeneficiaryBic	Código de identificación bancaria de la institución receptora.
Descripción Identifica el banco de destino del pago. Es una dimensión clave para el Dashboard «Causas raíz de los rechazos del beneficiario». Al agrupar los fallos por BIC del beneficiario, el banco puede identificar las contrapartes que rechazan instrucciones con frecuencia por problemas de calidad de los datos o requisitos de formato específicos. Por qué es importante Esencial para analizar el desempeño de las contrapartes y los patrones de rechazo. Dónde obtenerlo Campo 57A de SWIFT (institución donde se mantiene la cuenta) o 58A (institución del beneficiario). Ejemplos CITIUS33BARCGB22DRESDEFFHANDSEXX
	Código NAK de SWIFT SwiftNakCode	Código de error que devuelve la red SWIFT cuando rechaza un mensaje.
Descripción Contiene el código de error específico (p. ej., T26, T13) incluido en una respuesta negativa (NAK) de la red SWIFT. Este Atributo alimenta el Dashboard «Análisis de errores y retrabajo de SWIFT», que permite clasificar los fallos técnicos y priorizar las correcciones del sistema. Por qué es importante Permite identificar las causas técnicas de los rechazos en la red. Dónde obtenerlo Mensajes del sistema MT 015/019 o campo 451 en ACK/NAK. Ejemplos T26H01T13G02
	Divisa de la transacción TransactionCurrency	Código ISO de 3 letras que indica la moneda del pago.
Descripción Identifica la moneda en la que está denominado el pago (p. ej., USD, EUR, GBP). Es fundamental para el Dashboard «Rendimiento según la hora límite de la red», ya que las horas límite varían según la moneda. También permite analizar la eficiencia de la conversión de divisas al identificar pares de monedas distintas. Por qué es importante Determina las reglas de enrutamiento, las horas límite y los corredores de liquidación. Dónde obtenerlo Campo 32A (moneda) de SWIFT MT o elemento Ccy de ISO 20022. Ejemplos USDEURGBPJPY
	Es STP IsStp	Indicador que señala si el pago se procesó sin intervención manual.
Descripción Indicador booleano cuyo valor es True si el caso no contiene actividades de «Error identificado», «Pago rechazado» ni «Modificación» manual. Permite calcular directamente el KPI de procesamiento directo. Es la métrica principal para medir el éxito de la automatización del procesamiento de pagos. Por qué es importante La principal medida de la eficiencia del proceso y del estado de la automatización. Dónde obtenerlo Se calcula según la ausencia de actividades manuales o negativas específicas en el caso. Ejemplos truefalse
	Fecha valor ValueDate	Fecha en que los fondos deben estar disponibles para el beneficiario.
Descripción Representa la fecha de liquidación indicada en el mensaje de pago. Compararla con la marca de tiempo real de «Pago liquidado» ayuda en el Dashboard «Antigüedad de liquidaciones y conciliaciones». Indica la urgencia del pago y permite medir el cumplimiento de los acuerdos de nivel de servicio sobre la disponibilidad de los fondos. Por qué es importante Fundamental para gestionar la liquidez y medir la puntualidad de las liquidaciones. Dónde obtenerlo Campo 32A de SWIFT MT (subcampo de fecha) o IntrBkSttlmDt de ISO 20022. Ejemplos 2023-10-262023-11-01
	Importe de la transacción TransactionAmount	Valor monetario de la instrucción de pago.
Descripción Representa el importe principal que se transfiere. Este dato se extrae de campos específicos de SWIFT (por ejemplo, el campo 32A de MT103). Es esencial para el Dashboard de ciclos de aprobación de transferencias de gran importe, ya que permite segmentar los pagos por importe y analizar los retrasos de aprobación de las transacciones de alto riesgo y gran valor. Por qué es importante Permite analizar el impacto financiero y segmentar las transacciones por importe. Dónde obtenerlo Campo 32A de SWIFT MT (importe) o elemento IntrBkSttlmAmt de ISO 20022. Ejemplos 15000.001250.501000000.0045.00
	Tipo de mensaje SWIFT SwiftMessageType	Tipo de mensaje SWIFT utilizado (p. ej., MT103, pacs.008).
Descripción Indica el formato específico de la instrucción de pago. Entre los tipos más comunes se encuentran MT103 para transferencias de clientes y sus equivalentes en ISO 20022, como pacs.008. Se utiliza en el análisis de variantes del recorrido del pago para comparar la eficiencia de procesamiento de los formatos MT heredados con la de los nuevos estándares ISO. Por qué es importante Permite distinguir los flujos de pago y los estándares de procesamiento (heredados frente a ISO 20022). Dónde obtenerlo Bloque 2 de SWIFT (encabezado de aplicación), campo de tipo de mensaje. Ejemplos MT103MT202pacs.008MT101
	UETR UniqueEndToEndReference	Referencia única de extremo a extremo de la transacción, utilizada para el seguimiento en SWIFT gpi.
Descripción La UETR es una cadena de 36 caracteres que proporciona una referencia única e inmutable para un pago en toda la red SWIFT. A diferencia de los ID internos, la UETR se mantiene igual entre bancos. Este Atributo es fundamental para obtener visibilidad de extremo a extremo y correlacionar los registros internos con las actualizaciones de estado externas de SWIFT gpi. Por qué es importante El estándar de referencia para hacer seguimiento de pagos transfronterizos entre distintas instituciones. Dónde obtenerlo Bloque 3 de SWIFT, campo 121. Ejemplos b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Usuario que procesa ProcessingUser	Usuario o agente del sistema que realizó la actividad.
Descripción Identifica a la persona o al bot automatizado responsable de la actividad, como un responsable de cumplimiento que aprueba una coincidencia con una lista de sanciones o un operador que corrige un error de formato. Este Atributo alimenta el mapa de calor de errores de validación y permite a los responsables identificar necesidades de formación o usuarios concretos asociados con altas tasas de retrabajo. Por qué es importante Permite analizar los recursos e identificar cuellos de botella manuales. Dónde obtenerlo Registros de auditoría del sistema, columna «ID de usuario» en las tablas de transacciones. Ejemplos SISTEMAJ.DoeCompliance_Bot_01M.Smith
	Es transfronterizo IsCrossBorder	Indicador que señala si el pago involucra a distintos países.
Descripción Atributo booleano cuyo valor es True si el país del remitente es distinto del país del beneficiario. Permite calcular el KPI de latencia en la gestión de múltiples monedas al separar los flujos nacionales de los internacionales. Los pagos transfronterizos suelen tener mayor complejidad, costes y tiempos de procesamiento. Por qué es importante Segmentación fundamental para analizar la complejidad de los pagos. Dónde obtenerlo Comparación del código de país del BIC del remitente con el código de país del BIC del beneficiario. Ejemplos truefalse
	Motivo del rechazo RejectionReason	Descripción en texto que explica por qué se rechazó un pago.
Descripción Contiene la descripción narrativa o del código del fallo de un pago. Suele encontrarse en el campo 72 de SWIFT (información del remitente al receptor) o en los mensajes de devolución. Permite analizar las causas raíz de los rechazos del beneficiario. Los analistas pueden aplicar minería de texto para encontrar motivos de rechazo frecuentes (p. ej., «Cuenta no válida» o «El nombre del beneficiario no coincide»). Por qué es importante Aporta contexto cualitativo sobre los fallos del proceso. Dónde obtenerlo Campo 72 o 79 de SWIFT en los mensajes de devolución (devolución MT103). Ejemplos Cuenta del beneficiario cerradaIBAN no válidoIncumplimiento normativoIdentificador bancario desconocido
	País de origen OriginatingCountry	Código de país de la entidad que inicia el pago.
Descripción Indica la jurisdicción desde la que se originó la solicitud de pago. Es fundamental para el Dashboard «Tiempo de procesamiento de la revisión de sanciones», ya que los pagos procedentes de jurisdicciones de alto riesgo suelen someterse a comprobaciones de cumplimiento más rigurosas y prolongadas. Permite analizar geográficamente los volúmenes de pagos y los retrasos en el procesamiento. Por qué es importante Dimensión clave para analizar los riesgos de cumplimiento y el desempeño regional. Dónde obtenerlo Se obtiene del BIC del remitente (caracteres 5 y 6 del código de país). Ejemplos USGBDEFR
	Prioridad de la instrucción InstructionPriority	Indicador de prioridad que señala la urgencia del pago.
Descripción Se obtiene de los encabezados del mensaje (p. ej., «Normal» o «Urgente»). Permite segmentar los datos en el Dashboard «Ciclos de aprobación de transferencias de alto valor», ya que los pagos urgentes suelen requerir flujos de aprobación acelerados. Conocer la distribución de prioridades ayuda a planificar los recursos para los periodos de mayor actividad. Por qué es importante Ayuda a distinguir los requisitos de los acuerdos de nivel de servicio entre pagos estándar y acelerados. Dónde obtenerlo Bloque 2 de SWIFT, campo de prioridad del mensaje (p. ej., N para normal, U para urgente). Ejemplos NormalUrgenteSistema
	Se cumplió la hora límite MetCutOffTime	Indicador que señala si la instrucción se envió antes de la hora límite de la red.
Descripción Indicador booleano que se calcula comparando la hora de envío de la instrucción de pago con la hora límite de la red SWIFT para la moneda correspondiente. Permite calcular el KPI de cumplimiento de la hora límite de SWIFT. Si no se cumplen las horas límite, se producen retrasos en la liquidación que afectan a las posiciones de liquidez. Por qué es importante KPI operativo fundamental para la gestión de tesorería y liquidez. Dónde obtenerlo Se calcula comparando la marca de tiempo con una tabla de referencia estática de horas límite. Ejemplos truefalse

Obligatorio Recomendado Opcional

Actividades del procesamiento de pagos

Estos son los pasos e hitos clave que debe registrar en su Registro de eventos para descubrir el proceso con precisión e identificar cuellos de botella.

6 Recomendado 6 Opcional

	Actividad	Descripción
	Control de sanciones superado	Marca de tiempo en que la instrucción de pago supera correctamente el control de las listas de sanciones de la OFAC. Se registra explícitamente en los registros del sistema de cumplimiento o se infiere cuando se levanta el estado de retención por control.
Por qué es importante Es fundamental para el Dashboard de tiempo de entrega del control de sanciones. Los retrasos en esta etapa indican cuellos de botella de cumplimiento, no ineficiencias operativas. Dónde obtenerlo Registros del sistema de filtrado de cumplimiento o indicadores de estado de cumplimiento del centro de pagos. Capturar Se registra cuando se actualiza el estado del control Tipo de evento explicit
	Instrucción de pago enviada	Envío del mensaje con formato (MT103 o ISO 20022 pacs.008) al gateway SWIFT. Se registra explícitamente cuando se genera la carga del mensaje y se transfiere a la interfaz de red.
Por qué es importante Se utiliza para calcular la tasa de cumplimiento de los horarios de corte SWIFT. Marca el paso del procesamiento interno al procesamiento en la red. Dónde obtenerlo Registros de SWIFT Alliance Access (SAA) o registros de transmisión del gateway. Capturar Se registra cuando se genera el mensaje de salida Tipo de evento explicit
	Pago aprobado	Acción de autorización final realizada por una persona responsable designada o por una regla automatizada para transferencias de gran importe. Se registra explícitamente cuando el indicador del flujo de trabajo de aprobación se establece en verdadero.
Por qué es importante Es fundamental para el Dashboard de ciclos de aprobación de transferencias de gran importe. Permite identificar retrasos en las aprobaciones manuales de grandes movimientos de liquidez. Dónde obtenerlo Registro de auditoría del motor del flujo de trabajo de aprobación. Capturar Se registra cuando se ejecuta la acción de aprobación Tipo de evento explicit
	Pago conciliado	Conciliación de la transacción de pago con el extracto del libro de la cuenta Nostro/Vostro. Se infiere cuando el sistema de conciliación vincula el ID de la transacción con una línea del extracto.
Por qué es importante Cierra el ciclo financiero. Los retrasos en esta etapa afectan a la visibilidad del efectivo y a la capacidad de auditoría. Dónde obtenerlo Registros del sistema de conciliación o estado Conciliado en el sistema bancario central. Capturar Compare el estado de conciliación Tipo de evento inferred
	Pago liquidado	Confirmación de que los fondos se han abonado en la cuenta del beneficiario (a menudo, el estado gpi ACSC). Se registra explícitamente mediante actualizaciones del tracker o mensajes de confirmación.
Por qué es importante Representa la finalización efectiva de la cadena de pago. Es fundamental para calcular la brecha entre liquidación y conciliación. Dónde obtenerlo SWIFT gpi Tracker (estado ACSC) o confirmaciones MT900/910. Capturar Se registra cuando se confirma la liquidación Tipo de evento explicit
	Solicitud de pago creada	Generación inicial de la instrucción de pago en el sistema bancario interno o ERP. Se registra explícitamente cuando se asigna por primera vez una referencia única de transacción (TRN o UETR) a la orden de pago.
Por qué es importante Establece la hora de inicio de todo el ciclo de vida del pago. Es esencial para calcular los tiempos de procesamiento de principio a fin e identificar retrasos previos a la conexión con la red SWIFT. Dónde obtenerlo Marca de tiempo de creación de la tabla de transacciones en el sistema bancario central (CBS) o el centro de pagos. Capturar Se registra cuando se crea el registro de la transacción Tipo de evento explicit
	Confirmación ACK de SWIFT recibida	Recepción de una confirmación técnica (ACK) de la red SWIFT que confirma que el mensaje se aceptó para su procesamiento. Se registra explícitamente en los registros de la interfaz de red.
Por qué es importante Confirma que el mensaje se ha incorporado correctamente a la red global. Permite distinguir entre fallos internos y problemas reales de transmisión por la red. Dónde obtenerlo Registros del gateway SWIFT (para identificar las señales ACK y NACK). Capturar Se registra cuando se recibe el ACK de la red Tipo de evento explicit
	Datos del pago validados	Finalización satisfactoria de las comprobaciones de sintaxis y formato (por ejemplo, el formato del IBAN y la validez del BIC) de la instrucción de pago. A menudo se infiere cuando el estado de la transacción cambia de Borrador a Validado o Listo para autorizar.
Por qué es importante Una tasa alta de fallos en esta etapa indica una baja calidad de los datos en el origen. Mide el KPI de validación correcta al primer intento. Dónde obtenerlo Registros de estado del motor de pagos o tablas del historial de validación. Capturar Compare el campo de estado antes y después Tipo de evento inferred
	Error de pago identificado	Evento en el que una transacción se marca para su corrección debido a fallos de validación, NACK o mensajes de rechazo. Se infiere cuando la transacción entra en una cola de reparación, corrección o excepciones.
Por qué es importante Hace seguimiento de la tasa de trabajo adicional para resolver errores. Una frecuencia alta en esta etapa reduce drásticamente los índices de procesamiento directo (STP). Dónde obtenerlo Columnas de estado del centro de pagos o registros de la cola de excepciones. Capturar Compare el campo de estado con Error/Reparación Tipo de evento inferred
	Error de pago resuelto	Modificación y reenvío satisfactorios de una transacción que antes presentaba un error. Se infiere cuando la transacción pasa de una cola de reparación al estado de procesamiento o lista.
Por qué es importante Mide la eficiencia del equipo de corrección manual. Las duraciones prolongadas en esta etapa indican carencias de formación o códigos de error complejos. Dónde obtenerlo Registros de estado del centro de pagos que muestran la salida de las colas de excepciones. Capturar Compare el campo de estado al salir de Reparación Tipo de evento inferred
	Pago rechazado	Recepción de un mensaje de rechazo (devolución MT103 o estado gpi RJCT) de un banco beneficiario o intermediario. Se registra explícitamente a partir de los mensajes SWIFT entrantes.
Por qué es importante Es fundamental para el Dashboard de causas de rechazo del beneficiario. Permite identificar obstáculos externos, como cuentas cerradas o datos de enrutamiento incorrectos. Dónde obtenerlo Mensajes SWIFT entrantes (MT103 RET, pacs.004) o estado gpi RJCT. Capturar Se registra cuando se recibe el mensaje de rechazo Tipo de evento explicit
	Pago transferido	Actualización de estado intermedia (a menudo, el estado gpi ACSP) que indica que un banco intermediario está procesando el pago. Se registra mediante actualizaciones del SWIFT gpi Tracker o mensajes de estado.
Por qué es importante Ofrece visibilidad de los procesos de la banca corresponsal, que suelen ser opacos. Es esencial para analizar el recorrido completo de principio a fin. Dónde obtenerlo Fuentes de datos del SWIFT gpi Tracker o mensajes MT199/trck. Capturar Se registra cuando se recibe una actualización del tracker Tipo de evento explicit

Recomendado Opcional

Guías de extracción

Cómo obtener sus datos de SWIFT

Pasos

Inicie sesión en SWIFT Alliance WebPlatform o en la interfaz gráfica de Alliance Access con una cuenta de administrador que tenga acceso a la configuración de archivado.
Vaya al menú System Management, seleccione Archiving y, a continuación, Automated Archiving Configuration.
Configure un nuevo perfil de exportación diaria. En Target Directory, indique una ruta de red segura a la que puedan acceder sus scripts de extracción.
Especifique el alcance del contenido: seleccione 'Messages' y compruebe que estén marcadas las opciones 'Include History' e 'Include Interventions'. Esto es fundamental para capturar los eventos de auditoría, como las aprobaciones y validaciones.
Seleccione el formato de salida. Elija XML (en concreto, 'SAA XML v2' o el esquema más reciente disponible), ya que conserva mejor que CSV la relación jerárquica entre el encabezado del mensaje y los eventos del historial.
Configure los filtros de intervalo de fechas para extraer el período histórico que necesita para la iniciativa de Process Mining, o programe una ejecución diaria con datos de T-1.
Ejecute manualmente el trabajo de exportación del archivo para la carga inicial o espere a que finalice el trabajo por lotes programado. Compruebe que los archivos .xml se hayan generado en el directorio de destino.
Como la exportación de SAA es un archivo XML jerárquico y ProcessMind requiere un Registro de eventos CSV plano, debe ejecutar un script de transformación. Use el script de Python incluido en la sección Query para analizar el XML.
El script recorre cada elemento de mensaje. Extrae la referencia única de transacción de extremo a extremo (UETR) o el número de referencia de transacción (TRN) para usarlo como ID del caso.
A continuación, el script recorre los nodos secundarios 'History' e 'Intervention' de cada mensaje para generar filas de actividades. Asigna los códigos de estado internos de SAA (por ejemplo, 'NetworkAck' y 'Authorisation') a nombres de actividad estandarizados.
Ejecute el script de Python con los archivos XML exportados para generar el archivo plano 'events.csv'.
Valide el CSV para comprobar que columnas como EventTimestamp tengan el formato ISO 8601 y, después, cargue el archivo en ProcessMind.

Configuración

Formato del archivo: XML (preferido) o CSV (archivo plano). Se recomienda especialmente XML para capturar los nodos de historial anidados.
Incluir el texto del mensaje: Sí (necesario para analizar los datos de importe, moneda y beneficiario).
Incluir historial e intervenciones: Sí (obligatorio para ver aprobaciones, validaciones y errores).
Intervalo de fechas: Configure un período móvil (por ejemplo, los últimos 30 días) para las cargas incrementales o fechas fijas para el historial inicial.
Tipos de mensaje: Filtre por MT103, MT202, pacs.008, pacs.009 y pacs.004/002 (para devoluciones y estados).
Direcciones: Incluya tanto los mensajes de entrada (emisión) como los de salida (recepción) para capturar rechazos o confirmaciones entrantes.
Seguridad: Asegúrese de que la carpeta de exportación tenga permisos estrictos de lectura y escritura, ya que estos archivos contienen datos de pagos activos.

Consulta de ejemplo python

import xml.etree.ElementTree as ET
import pandas as pd
import glob
import os

class=class="hl-string">"hl-comment"># CONFIGURATION
class=class="hl-string">"hl-comment"># Update this path to your SAA XML Export directory
input_folder = class="hl-string">"./saa_exports/"
output_file = class="hl-string">"./swift_process_mining_log.csv"

columns = [
    class="hl-string">"PaymentTransactionId", class="hl-string">"ActivityName", class="hl-string">"EventTimestamp", class="hl-string">"SourceSystem", 
    class="hl-string">"LastDataUpdate", class="hl-string">"TransactionAmount", class="hl-string">"TransactionCurrency", class="hl-string">"UniqueEndToEndReference",
    class="hl-string">"SwiftMessageType", class="hl-string">"ProcessingUser", class="hl-string">"BeneficiaryBic", class="hl-string">"SwiftNakCode", class="hl-string">"ValueDate", class="hl-string">"IsStp"
]

data_rows = []

class=class="hl-string">"hl-comment"># Helper to determine Activity Name based on SAA History Events
def map_activity(history_item_name, status, nature, text_content):
    class=class="hl-string">"hl-comment"># 1. Payment Request Created
    if history_item_name == class="hl-string">"Creation" or history_item_name == class="hl-string">"Reception":
        return class="hl-string">"Payment Request Created"
    
    class=class="hl-string">"hl-comment"># 2. Payment Details Validated
    if class="hl-string">"Validation" in history_item_name and status == class="hl-string">"Success":
        return class="hl-string">"Payment Details Validated"
    
    class=class="hl-string">"hl-comment"># 3. Sanctions Screening Passed
    if class="hl-string">"Filter" in history_item_name and status == class="hl-string">"Passed":
        return class="hl-string">"Sanctions Screening Passed"
    
    class=class="hl-string">"hl-comment"># 4. Payment Approved
    if history_item_name == class="hl-string">"Intervention" and nature == class="hl-string">"Authorization":
        return class="hl-string">"Payment Approved"
    
    class=class="hl-string">"hl-comment"># 5. Payment Instruction Sent
    if history_item_name == class="hl-string">"Transmission" or status == class="hl-string">"Transmitted":
        return class="hl-string">"Payment Instruction Sent"
    
    class=class="hl-string">"hl-comment"># 6. SWIFT ACK Received
    if history_item_name == class="hl-string">"NetworkReport" and class="hl-string">"ACK" in text_content:
        return class="hl-string">"SWIFT ACK Received"

    class=class="hl-string">"hl-comment"># 7. Payment Transferred (gpi status)
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"ACSP" in text_content:
        return class="hl-string">"Payment Transferred"

    class=class="hl-string">"hl-comment"># 8. Payment Error Identified
    if nature == class="hl-string">"NAK" or status == class="hl-string">"Failed" or nature == class="hl-string">"RoutingFailure":
        return class="hl-string">"Payment Error Identified"

    class=class="hl-string">"hl-comment"># 9. Payment Error Resolved
    if history_item_name == class="hl-string">"Modification" and nature == class="hl-string">"Repair":
        return class="hl-string">"Payment Error Resolved"
    
    class=class="hl-string">"hl-comment"># 10. Payment Rejected
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"RJCT" in text_content:
        return class="hl-string">"Payment Rejected"

    class=class="hl-string">"hl-comment"># 11. Payment Settled
    if class="hl-string">"TrackerUpdate" in history_item_name and class="hl-string">"ACSC" in text_content:
        return class="hl-string">"Payment Settled"

    class=class="hl-string">"hl-comment"># 12. Payment Reconciled
    class=class="hl-string">"hl-comment"># Often external, but if SAA receives a Reconciliation update:
    if history_item_name == class="hl-string">"ReconciliationMatch":
        return class="hl-string">"Payment Reconciled"
        
    return None

class=class="hl-string">"hl-comment"># PROCESS XML FILES
for xml_file in glob.glob(os.path.join(input_folder, class="hl-string">"*.xml")):
    tree = ET.parse(xml_file)
    root = tree.getroot()

    class=class="hl-string">"hl-comment"># Iterate through Messages
    for message in root.findall(class="hl-string">".//Message"):
        class=class="hl-string">"hl-comment"># Header Extraction
        trn = message.findtext(class="hl-string">"TRN")
        uetr = message.findtext(class="hl-string">"UETR")
        case_id = uetr if uetr else trn
        
        class=class="hl-string">"hl-comment"># Skip if no identifier found
        if not case_id: 
            continue

        msg_type = message.findtext(class="hl-string">"Type")
        amount = message.findtext(class="hl-string">"Amount")
        currency = message.findtext(class="hl-string">"Currency")
        val_date = message.findtext(class="hl-string">"ValueDate")
        ben_bic = message.findtext(class="hl-string">"BeneficiaryBIC")
        
        class=class="hl-string">"hl-comment"># Loop through History/Audit Trail for Activities
        for history in message.findall(class="hl-string">".//History/Item"):
            evt_name = history.findtext(class="hl-string">"Name")
            evt_status = history.findtext(class="hl-string">"Status")
            evt_nature = history.findtext(class="hl-string">"Nature")
            evt_text = history.findtext(class="hl-string">"Text") or class="hl-string">""
            evt_user = history.findtext(class="hl-string">"Operator")
            evt_time = history.findtext(class="hl-string">"Time") class=class="hl-string">"hl-comment"># format: YYYYMMDDHHMMSS
            
            activity = map_activity(evt_name, evt_status, evt_nature, evt_text)
            
            if activity:
                class=class="hl-string">"hl-comment"># Determine NAK Code if applicable
                nak_code = None
                if activity == class="hl-string">"Payment Error Identified" and class="hl-string">"NAK" in evt_text:
                    nak_code = evt_text.split(class="hl-string">"Code:")[-1].strip()
                
                class=class="hl-string">"hl-comment"># Determine STP
                is_stp = class="hl-string">"True" if evt_user == class="hl-string">"System" or evt_user == class="hl-string">"Auto" else class="hl-string">"False"

                data_rows.append({
                    class="hl-string">"PaymentTransactionId": case_id,
                    class="hl-string">"ActivityName": activity,
                    class="hl-string">"EventTimestamp": pd.to_datetime(evt_time, format=class="hl-string">'%Y%m%d%H%M%S'),
                    class="hl-string">"SourceSystem": class="hl-string">"SWIFT Alliance Access",
                    class="hl-string">"LastDataUpdate": pd.Timestamp.now(),
                    class="hl-string">"TransactionAmount": amount,
                    class="hl-string">"TransactionCurrency": currency,
                    class="hl-string">"UniqueEndToEndReference": uetr,
                    class="hl-string">"SwiftMessageType": msg_type,
                    class="hl-string">"ProcessingUser": evt_user,
                    class="hl-string">"BeneficiaryBic": ben_bic,
                    class="hl-string">"SwiftNakCode": nak_code,
                    class="hl-string">"ValueDate": val_date,
                    class="hl-string">"IsStp": is_stp
                })

class=class="hl-string">"hl-comment"># OUTPUT GENERATION
df = pd.DataFrame(data_rows, columns=columns)

class=class="hl-string">"hl-comment"># Remove duplicate timestamp/activity pairs for cleaner log
df.drop_duplicates(subset=[class="hl-string">"PaymentTransactionId", class="hl-string">"ActivityName", class="hl-string">"EventTimestamp"], inplace=True)

df.to_csv(output_file, index=False, quoting=1)
print(fclass="hl-string">"Extraction Complete. Processed {len(df)} events into {output_file}")

Pasos

Prepare el entorno: Compruebe que Python 3.8 o una versión posterior esté instalado en el servidor de extracción. Instale las bibliotecas necesarias con pip (pandas, numpy). Cree un directorio de trabajo específico con una subcarpeta llamada raw_swift_files y coloque allí todos los archivos diarios .out, .txt o .fin.
Revise la estructura de los archivos: Los mensajes SWIFT FIN sin procesar están organizados en bloques ({1: Header} {2: Application} {4: Body}). Identifique los delimitadores. Los archivos estándar usan llaves. Compruebe que los archivos no estén dentro de contenedores propietarios (como encabezados RJE) o elimine esos contenedores antes del procesamiento.
Configure las rutas del script: Abra el script de Python proporcionado. Actualice la variable INPUT_DIRECTORY para que apunte a la carpeta raw_swift_files. Actualice la ruta de OUTPUT_FILE para el CSV resultante.
Defina los patrones de expresiones regulares: El script usa expresiones regulares para aislar los bloques. El bloque 1 contiene el BIC del remitente y el número de secuencia. El bloque 2 contiene el tipo de mensaje (por ejemplo, I103, O103) y el BIC del destinatario. El bloque 4 contiene las etiquetas de datos comerciales (por ejemplo, :20: TRN, :32A: valor/importe).
Asigne los tipos de mensaje a las actividades: El script incluye un diccionario de asignaciones. MT103 corresponde a 'Instrucción de pago enviada'. MT012 (acuse de recibo del sistema) corresponde a 'Acuse de recibo de SWIFT recibido'. MT900/910 corresponde a 'Pago liquidado'. MT199/299 con códigos de estado específicos (ACSP, RJCT) se asigna a 'Pago transferido' o 'Pago rechazado'.
Extraiga los atributos: El analizador recorre etiquetas específicas. :20: se asigna a Payment Transaction ID. :121: se asigna a UETR. :32A: se analiza para obtener la fecha, la moneda y el importe.
Gestione los estados internos: Para actividades como 'Solicitud de pago creada' o 'Pago aprobado', que suelen ser eventos internos del ERP y no aparecen en los archivos SWIFT, el script las deduce de la marca de tiempo de creación del mensaje en el bloque 1 si no hay registros explícitos, o busca códigos de texto específicos en el campo :72: (información del remitente al destinatario) si su organización registra allí las aprobaciones.
Ejecute la extracción: Ejecute el script desde la línea de comandos: python swift_parser.py. El script recorre todos los archivos, analiza los bloques SWIFT válidos y omite las líneas con formato incorrecto.
Valide los datos después del procesamiento: Abra el CSV generado. Compruebe el formato de EventTimestamp (se recomienda ISO 8601). Asegúrese de que todas las filas tengan un valor en PaymentTransactionId para poder agrupar los casos.
Transforme los datos: Si 'ValueDate' aparece como YYMMDD, el script lo convierte a YYYY-MM-DD. Compruebe que los separadores decimales de 'TransactionAmount' estén estandarizados (puntos o comas).
Realice la revisión final: Filtre por un UETR específico para ver el flujo completo, desde el envío de la instrucción hasta el acuse de recibo y la liquidación. Compruebe que los NAK (MT019) aparezcan como 'Error de pago identificado'.
Cargue los datos en ProcessMind: Importe el CSV. Asigne PaymentTransactionId a ID del caso, ActivityName a Actividad y EventTimestamp a Marca de tiempo.

Configuración

Directorio de entrada: Ruta a la carpeta que contiene los archivos planos FIN/MT sin procesar. Asegúrese de que se hayan concedido permisos de lectura.
Análisis del formato de fecha: Las fechas SWIFT sin procesar usan el formato YYMMDD. El script gestiona la interpretación del siglo (20xx).
Filtros de tipo de mensaje: El script se centra en la categoría 1 (pagos), la 9 (estados de cuenta) y los mensajes de sistema habituales (012, 019). Ajuste la lista RELEVANT_MT_TYPES si necesita la categoría 2 (transferencias entre instituciones financieras).
Codificación: De forma predeterminada, se usa 'utf-8'. Cambie a 'latin-1' o 'ascii' si los archivos contienen caracteres de codificaciones antiguas.
Procesamiento por lotes: Para conjuntos de datos de más de 1 GB, el script usa un generador para evitar que se agote la memoria y procesa los archivos uno por uno.
Ajuste de expresiones regulares: La expresión regular estricta presupone el formato FIN estándar {1:...}{2:...}{4:...}. Si los archivos usan $ u otros delimitadores, actualice la variable BLOCK_PATTERN.

Consulta de ejemplo python

import os
import re
import glob
import pandas as pd
from datetime import datetime

class=class="hl-string">"hl-comment"># === CONFIGURATION ===
INPUT_DIRECTORY = class="hl-string">"./raw_swift_files/"
OUTPUT_FILE = class="hl-string">"./extracted_swift_event_log.csv"

class=class="hl-string">"hl-comment"># === REGEX PATTERNS ===
class=class="hl-string">"hl-comment"># Matches standard SWIFT block structure: {1:...}{2:...}{3:...}{4:...}
BLOCK_PATTERN = re.compile(rclass="hl-string">'(\{1:.*?\})(\{2:.*?\})(?:\{3:.*?\})?(\{4:.*?\})', re.DOTALL)

class=class="hl-string">"hl-comment"># Field extractors
TAG_20_TRN = re.compile(rclass="hl-string">':20:([^\r\n]+)')
TAG_121_UETR = re.compile(rclass="hl-string">':121:([a-fA-F0-9\-]+)')
TAG_32A_VAL = re.compile(rclass="hl-string">':32A:(\d{6})([A-Z]{3})([\d,]+)')
TAG_72_INFO = re.compile(rclass="hl-string">':72:([^\r\n]+)')
TAG_57A_BIC = re.compile(rclass="hl-string">':57[A-Z]?:(?:[/]{0,2}[A-Z0-9]+)?\r?\n?([A-Z0-9]{8,11})')

class=class="hl-string">"hl-comment"># Header parsers
BLOCK_1_DATE = re.compile(rclass="hl-string">'\{1:[F|A|L]01[A-Z0-9]{12}(\d{4})(\d{6})')
BLOCK_2_TYPE = re.compile(rclass="hl-string">'\{2:([IO])(\d{3})')

class=class="hl-string">"hl-comment"># === ACTIVITY MAPPING LOGIC ===
def map_message_to_activity(io_direction, mt_type, block4_text):
    class=class="hl-string">"hl-comment"># Outgoing Payments (MT103, MT202)
    if io_direction == class="hl-string">'I' and mt_type in [class="hl-string">'103', class="hl-string">'202']:
        return class="hl-string">"Payment Instruction Sent"
    
    class=class="hl-string">"hl-comment"># Incoming Payments (MT103 received from another bank)
    if io_direction == class="hl-string">'O' and mt_type in [class="hl-string">'103', class="hl-string">'202']:
        return class="hl-string">"Payment Transferred"

    class=class="hl-string">"hl-comment"># System Acknowledgment (MT012)
    if mt_type == class="hl-string">'012':
        return class="hl-string">"SWIFT ACK Received"

    class=class="hl-string">"hl-comment"># System NAK / Abort (MT019)
    if mt_type == class="hl-string">'019':
        return class="hl-string">"Payment Error Identified"

    class=class="hl-string">"hl-comment"># Statements / Confirmation (MT900 Debit, MT910 Credit, MT950)
    if mt_type in [class="hl-string">'900', class="hl-string">'910', class="hl-string">'910', class="hl-string">'950']:
        return class="hl-string">"Payment Settled"
    
    class=class="hl-string">"hl-comment"># Returns (MT103 RETN)
    if mt_type == class="hl-string">'103' and class="hl-string">':23E:RETN' in block4_text:
        return class="hl-string">"Payment Rejected"

    class=class="hl-string">"hl-comment"># GPI Status Updates (MT199)
    if mt_type == class="hl-string">'199':
        if class="hl-string">'/RJCT/' in block4_text:
            return class="hl-string">"Payment Rejected"
        if class="hl-string">'/ACSP/' in block4_text:
            return class="hl-string">"Payment Transferred"
        if class="hl-string">'/ACSC/' in block4_text:
            return class="hl-string">"Payment Settled"
            
    return class="hl-string">"Message Processed"  class=class="hl-string">"hl-comment"># Fallback

def parse_swift_date(yymmdd):
    class=class="hl-string">"hl-comment"># Assumes 20xx for years
    try:
        return datetime.strptime(yymmdd, class="hl-string">'%y%m%d').strftime(class="hl-string">'%Y-%m-%d')
    except ValueError:
        return None

class=class="hl-string">"hl-comment"># === MAIN EXTRACTION ===
def process_files():
    records = []
    files = glob.glob(os.path.join(INPUT_DIRECTORY, class="hl-string">"*"))
    
    print(fclass="hl-string">"Found {len(files)} files to process.")

    for filepath in files:
        try:
            with open(filepath, class="hl-string">'r', encoding=class="hl-string">'utf-8', errors=class="hl-string">'ignore') as f:
                content = f.read()
                
            class=class="hl-string">"hl-comment"># Find all full messages in file
            messages = BLOCK_PATTERN.findall(content)
            
            for b1, b2, b4 in messages:
                class=class="hl-string">"hl-comment"># -- Extract Core IDs --
                trn_match = TAG_20_TRN.search(b4)
                uetr_match = TAG_121_UETR.search(b4)
                
                class=class="hl-string">"hl-comment"># Primary Key preference: UETR > TRN > Generated ID
                uetr = uetr_match.group(1) if uetr_match else None
                trn = trn_match.group(1) if trn_match else class="hl-string">"UNKNOWN"
                case_id = uetr if uetr else trn
                
                if case_id == class="hl-string">"UNKNOWN":
                    continue class=class="hl-string">"hl-comment"># Skip structural noise

                class=class="hl-string">"hl-comment"># -- Extract Metadata --
                type_match = BLOCK_2_TYPE.search(b2)
                io_dir = type_match.group(1) if type_match else class="hl-string">"I"
                mt_type = type_match.group(2) if type_match else class="hl-string">"999"
                
                class=class="hl-string">"hl-comment"># -- Determine Timestamp --
                class=class="hl-string">"hl-comment"># Attempt to find timestamp in Block 1 (Session header)
                class=class="hl-string">"hl-comment"># Format often: {1:F01BANKBEBBXXXX1234123456}
                class=class="hl-string">"hl-comment"># Using current time as fallback if header parsing fails
                timestamp = datetime.now().isoformat()
                date_match = BLOCK_1_DATE.search(b1)
                if date_match:
                    class=class="hl-string">"hl-comment"># YYMMDD + HHMM
                    class=class="hl-string">"hl-comment"># Note: Sequence number often occupies this space, this regex is generic
                    class=class="hl-string">"hl-comment"># For simplicity, we assume file creation time or construct from header
                    pass 
                    
                class=class="hl-string">"hl-comment"># -- Extract Financials --
                amount = None
                currency = None
                val_date = None
                amt_match = TAG_32A_VAL.search(b4)
                if amt_match:
                    val_date_raw, currency, amt_str = amt_match.groups()
                    val_date = parse_swift_date(val_date_raw)
                    amount = float(amt_str.replace(class="hl-string">',', class="hl-string">'.'))

                class=class="hl-string">"hl-comment"># -- Extract Beneficiary --
                ben_bic = None
                ben_match = TAG_57A_BIC.search(b4)
                if ben_match:
                    ben_bic = ben_match.group(1)

                class=class="hl-string">"hl-comment"># -- Map Activity --
                activity = map_message_to_activity(io_dir, mt_type, b4)

                class=class="hl-string">"hl-comment"># -- Create Record --
                record = {
                    class="hl-string">"PaymentTransactionId": case_id,
                    class="hl-string">"ActivityName": activity,
                    class="hl-string">"EventTimestamp": datetime.now().strftime(class="hl-string">"%Y-%m-%d %H:%M:%S"), class=class="hl-string">"hl-comment"># Replace with actual extracted time
                    class="hl-string">"SourceSystem": class="hl-string">"SWIFT_Alliance_Access",
                    class="hl-string">"TransactionAmount": amount,
                    class="hl-string">"TransactionCurrency": currency,
                    class="hl-string">"UniqueEndToEndReference": uetr,
                    class="hl-string">"SwiftMessageType": fclass="hl-string">"MT{mt_type}",
                    class="hl-string">"BeneficiaryBic": ben_bic,
                    class="hl-string">"ValueDate": val_date,
                    class="hl-string">"LastDataUpdate": datetime.now().isoformat()
                }
                
                records.append(record)

                class=class="hl-string">"hl-comment"># -- Derived Logic for class="hl-string">'Created' --
                class=class="hl-string">"hl-comment"># If this is the very first outgoing MT103, we can imply creation
                class=class="hl-string">"hl-comment"># In a real scenario, this logic happens after sorting all events
                if activity == class="hl-string">"Payment Instruction Sent":
                    creation_record = record.copy()
                    creation_record[class="hl-string">"ActivityName"] = class="hl-string">"Payment Request Created"
                    class=class="hl-string">"hl-comment"># Offset time slightly backwards to simulate flow
                    creation_record[class="hl-string">"EventTimestamp"] = class="hl-string">"[Derive from Log Creation Time]"
                    records.append(creation_record)

        except Exception as e:
            print(fclass="hl-string">"Error processing file {filepath}: {e}")

    class=class="hl-string">"hl-comment"># -- Convert to DataFrame --
    df = pd.DataFrame(records)
    
    class=class="hl-string">"hl-comment"># -- Final Cleanup --
    class=class="hl-string">"hl-comment"># Sort by ID and Time to ensure logical order if needed
    if not df.empty:
        df.sort_values(by=[class="hl-string">'PaymentTransactionId', class="hl-string">'EventTimestamp'], inplace=True)
        df.to_csv(OUTPUT_FILE, index=False)
        print(fclass="hl-string">"Extraction complete. Data saved to {OUTPUT_FILE}")
    else:
        print(class="hl-string">"No valid SWIFT messages found.")

if __name__ == class="hl-string">"__main__":
    process_files()

Pasos

Confirme que dispone de una suscripción a la API de SWIFT gpi Tracker, credenciales de API, capacidad de búsqueda por UETR y acceso a la fuente de eventos del sistema de pagos interno. Consulte la documentación del servicio SWIFT para obtener la URL base exacta de la API, el método de autenticación, el esquema de respuesta, los límites de solicitudes y las reglas de paginación. No dé por sentado que existe una ruta de endpoint determinada, ya que depende del servicio SWIFT con licencia y de su implementación.
Configure el script con la cadena de conexión, las credenciales, el intervalo de fechas y los filtros específicos de su empresa. Para la extracción inicial, use un intervalo de tres a seis meses. Limite los datos de la fuente interna a las transacciones de pago que tengan un TRN o UETR y conserve el nombre del sistema de origen de cada evento.
Extraiga los eventos del ciclo de vida interno correspondientes a Solicitud de pago creada, Datos del pago validados, Revisión de sanciones superada, Pago aprobado, Instrucción de pago enviada, Acuse de recibo de SWIFT recibido, Error de pago identificado, Error de pago resuelto, Pago rechazado, Pago liquidado y Pago conciliado. Cada evento de origen debe convertirse en una fila independiente del Registro de eventos. No espere que ProcessMind deduzca las actividades.
Extraiga los UETR de los registros de pagos internos y consulte la API con licencia de SWIFT gpi Tracker para cada UETR. Use la documentación de la API correspondiente a su entorno para configurar la URL de solicitud, los encabezados de autenticación, los parámetros, la paginación y los campos de respuesta. Guarde la respuesta sin procesar para facilitar las auditorías.
Convierta los estados pertinentes de gpi Tracker en filas de eventos explícitas. El script asigna ACSP a Pago transferido, RJCT a Pago rechazado y ACSC a Pago liquidado. Si la respuesta con licencia usa otros nombres de estado o marcas de tiempo, actualice la asignación de estados según el esquema de respuesta documentado. No cree un evento si la API no proporciona la ocurrencia de estado correspondiente.
Normalice todas las marcas de tiempo a una zona horaria uniforme, preferiblemente UTC, y conserve la marca original cuando sea necesario para las auditorías. Convierta los valores monetarios a valores numéricos, mantenga la moneda de la transacción, normalice los valores booleanos de STP y conserve los valores NULL cuando la fuente no proporcione un atributo.
Elimine los eventos duplicados usando PaymentTransactionId, ActivityName, EventTimestamp y el identificador de evento de origen más específico disponible. Conserve las ocurrencias legítimas múltiples, como los ciclos repetidos de reparación y reenvío, salvo que una regla de negocio exija explícitamente una sola ocurrencia por actividad.
Valide que cada fila de salida contenga PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem y LastDataUpdate. Compruebe que ActivityName solo incluya los valores de actividad documentados y que las 12 actividades estén representadas cuando aparezcan en los datos de origen.
Exporte el conjunto de datos resultante como CSV UTF-8 o en otro formato de Registro de eventos compatible con ProcessMind. Use una fila por evento, incluya las columnas obligatorias y recomendadas, y asigne PaymentTransactionId como identificador del caso, ActivityName como actividad y EventTimestamp como marca de tiempo del evento. Cargue el archivo en ProcessMind sin esperar que se deduzcan eventos adicionales.

Configuración

Endpoint y esquema de la API: Configure la URL base exacta de la API de SWIFT gpi Tracker, la ruta del recurso, los parámetros de solicitud, los encabezados de autenticación, la paginación y los nombres de los campos de respuesta según la documentación de SWIFT con licencia para su entorno. El script no inventa deliberadamente un endpoint.
Credenciales y autorización: Use el mecanismo aprobado para las credenciales de la API de SWIFT, los requisitos de certificados o tokens, el método de almacenamiento de secretos y las autorizaciones del sistema de origen interno. No incluya secretos de producción directamente en el código fuente.
Intervalo de fechas: Comience con un período de tres a seis meses. Use la marca de tiempo del evento o la fecha de creación del pago que corresponda a sus objetivos de generación de informes. Para volúmenes grandes, procese períodos más cortos y guarde puntos de control para los UETR completados.
Filtros de la fuente interna: Configure los filtros de empresa, entidad legal, sucursal, producto de pago, tipo de documento, tipo de mensaje, moneda y estado según su sistema. Use marcadores como [Configure based on your system] hasta confirmar el esquema de origen.
Asignación de actividades: Mantenga asignaciones explícitas para los estados y las colas internas. Por ejemplo, asigne Borrador a Validado o Listo para autorización para Datos del pago validados; la liberación de una retención de revisión a Revisión de sanciones superada; la entrada en una cola de reparación o excepciones a Error de pago identificado; y el regreso al procesamiento o al estado Listo para el pago a Error de pago resuelto.
Asignación de estados de gpi: Asigne los estados documentados de Tracker a actividades explícitas. Esta implementación asigna ACSP a Pago transferido, RJCT a Pago rechazado y ACSC a Pago liquidado. Amplíe la asignación solo cuando la documentación de la API con licencia confirme el significado de los estados.
Política de marcas de tiempo: Normalice las marcas de tiempo a UTC siempre que sea posible. Defina la prioridad entre la hora del evento de origen, la hora del evento de Tracker, la hora de recepción del mensaje y la hora de extracción. LastDataUpdate debe representar la hora de extracción o actualización, no la hora del evento de negocio.
Límites de solicitudes y reintentos: Configure el tiempo de espera de las solicitudes, el número de reintentos, la espera exponencial, la gestión de estados HTTP y la paginación. Respete los límites del servicio SWIFT y evite las solicitudes paralelas sin control.
Rendimiento: Almacene en caché las respuestas por UETR, procese los UETR por lotes, guarde puntos de control y use la extracción incremental cuando esté disponible. Evite consultar Tracker repetidamente para el mismo UETR y el mismo intervalo de fechas.
Calidad de los datos: Exija PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem y LastDataUpdate. Permita valores NULL en los atributos recomendados cuando la fuente no los proporcione, pero informe sobre sus tasas de cobertura.
Auditabilidad: Guarde la respuesta sin procesar de la API, la hora de la solicitud, el estado de la respuesta, el UETR y el identificador de la ejecución de extracción en una ubicación de auditoría aprobada. Aplique las reglas de retención y seguridad exigidas para los datos de pagos.
Requisitos previos: Confirme que tiene acceso a los registros del ciclo de vida de los pagos internos, cumplimiento, pasarela SWIFT, conciliación e interfaces de mensajes, además de la licencia de la API de SWIFT gpi Tracker y los certificados o permisos de red necesarios.

Consulta de ejemplo python

import csv
import json
import os
import time
import uuid
from datetime import datetime, timezone
from decimal import Decimal, InvalidOperation
from typing import Any, Dict, Iterable, List, Optional

import requests

class=class="hl-string">"hl-comment"># Replace only the following placeholders with environment-specific values.
SWIFT_API_BASE_URL = class="hl-string">"[SWIFT gpi Tracker API base URL]"
SWIFT_API_PATH = class="hl-string">"[SWIFT gpi Tracker API resource path]"
SWIFT_API_TOKEN = class="hl-string">"[SWIFT API token or credential reference]"
START_DATE = class="hl-string">"[YYYY-MM-DD]"
END_DATE = class="hl-string">"[YYYY-MM-DD]"
COMPANY_FILTER = class="hl-string">"[Configure based on your system]"
INTERNAL_EVENTS_FILE = class="hl-string">"[path to internal payment lifecycle events CSV or JSON]"
OUTPUT_FILE = class="hl-string">"swift_gpi_event_log.csv"
RAW_RESPONSE_FILE = class="hl-string">"swift_gpi_raw_responses.jsonl"
REQUEST_TIMEOUT_SECONDS = 60
MAX_RETRIES = 4
PAGE_SIZE = 100

REQUIRED_COLUMNS = [
    class="hl-string">"PaymentTransactionId",
    class="hl-string">"ActivityName",
    class="hl-string">"EventTimestamp",
    class="hl-string">"SourceSystem",
    class="hl-string">"LastDataUpdate",
]

RECOMMENDED_COLUMNS = [
    class="hl-string">"TransactionAmount",
    class="hl-string">"TransactionCurrency",
    class="hl-string">"UniqueEndToEndReference",
    class="hl-string">"SwiftMessageType",
    class="hl-string">"ProcessingUser",
    class="hl-string">"BeneficiaryBic",
    class="hl-string">"SwiftNakCode",
    class="hl-string">"ValueDate",
    class="hl-string">"IsStp",
]

ALL_ACTIVITIES = {
    class="hl-string">"Payment Request Created",
    class="hl-string">"Payment Details Validated",
    class="hl-string">"Sanctions Screening Passed",
    class="hl-string">"Payment Approved",
    class="hl-string">"Payment Instruction Sent",
    class="hl-string">"SWIFT ACK Received",
    class="hl-string">"Payment Transferred",
    class="hl-string">"Payment Error Identified",
    class="hl-string">"Payment Error Resolved",
    class="hl-string">"Payment Rejected",
    class="hl-string">"Payment Settled",
    class="hl-string">"Payment Reconciled",
}


def utc_now() -> str:
    return datetime.now(timezone.utc).isoformat()


def first_value(record: Dict[str, Any], names: Iterable[str], default: Any = None) -> Any:
    for name in names:
        if name in record and record[name] not in (None, class="hl-string">""):
            return record[name]
    return default


def normalize_timestamp(value: Any) -> Optional[str]:
    if value in (None, class="hl-string">""):
        return None
    text = str(value).strip()
    if text.endswith(class="hl-string">"Z"):
        text = text[:-1] + class="hl-string">"+00:00"
    try:
        parsed = datetime.fromisoformat(text)
        if parsed.tzinfo is None:
            parsed = parsed.replace(tzinfo=timezone.utc)
        return parsed.astimezone(timezone.utc).isoformat()
    except ValueError:
        return str(value)


def normalize_amount(value: Any) -> Optional[str]:
    if value in (None, class="hl-string">""):
        return None
    try:
        return str(Decimal(str(value)))
    except (InvalidOperation, ValueError):
        return str(value)


def normalize_bool(value: Any) -> Optional[bool]:
    if value in (None, class="hl-string">""):
        return None
    if isinstance(value, bool):
        return value
    return str(value).strip().lower() in {class="hl-string">"true", class="hl-string">"1", class="hl-string">"yes", class="hl-string">"y"}


def load_records(path: str) -> List[Dict[str, Any]]:
    if path.lower().endswith(class="hl-string">".json"):
        with open(path, class="hl-string">"r", encoding=class="hl-string">"utf-8") as handle:
            data = json.load(handle)
        if isinstance(data, list):
            return data
        if isinstance(data, dict):
            for key in (class="hl-string">"records", class="hl-string">"events", class="hl-string">"payments", class="hl-string">"data"):
                if isinstance(data.get(key), list):
                    return data[key]
        raise ValueError(class="hl-string">"The JSON input must contain a list of records.")
    with open(path, class="hl-string">"r", encoding=class="hl-string">"utf-8-sig", newline=class="hl-string">"") as handle:
        return list(csv.DictReader(handle))


def base_event(payment: Dict[str, Any], activity: str, timestamp: Any, source_system: str, run_time: str) -> Optional[Dict[str, Any]]:
    payment_id = first_value(payment, [class="hl-string">"PaymentTransactionId", class="hl-string">"payment_transaction_id", class="hl-string">"transaction_id", class="hl-string">"TRN", class="hl-string">"trn", class="hl-string">"UETR", class="hl-string">"uetr"])
    event_time = normalize_timestamp(timestamp)
    if not payment_id or not event_time:
        return None
    return {
        class="hl-string">"PaymentTransactionId": str(payment_id),
        class="hl-string">"ActivityName": activity,
        class="hl-string">"EventTimestamp": event_time,
        class="hl-string">"SourceSystem": source_system,
        class="hl-string">"LastDataUpdate": run_time,
        class="hl-string">"TransactionAmount": normalize_amount(first_value(payment, [class="hl-string">"TransactionAmount", class="hl-string">"transaction_amount", class="hl-string">"amount"])),
        class="hl-string">"TransactionCurrency": first_value(payment, [class="hl-string">"TransactionCurrency", class="hl-string">"transaction_currency", class="hl-string">"currency"]),
        class="hl-string">"UniqueEndToEndReference": first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr", class="hl-string">"uetr_value"]),
        class="hl-string">"SwiftMessageType": first_value(payment, [class="hl-string">"SwiftMessageType", class="hl-string">"swift_message_type", class="hl-string">"message_type"]),
        class="hl-string">"ProcessingUser": first_value(payment, [class="hl-string">"ProcessingUser", class="hl-string">"processing_user", class="hl-string">"user", class="hl-string">"performed_by"]),
        class="hl-string">"BeneficiaryBic": first_value(payment, [class="hl-string">"BeneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"]),
        class="hl-string">"SwiftNakCode": first_value(payment, [class="hl-string">"SwiftNakCode", class="hl-string">"swift_nak_code", class="hl-string">"nak_code"]),
        class="hl-string">"ValueDate": first_value(payment, [class="hl-string">"ValueDate", class="hl-string">"value_date"]),
        class="hl-string">"IsStp": normalize_bool(first_value(payment, [class="hl-string">"IsStp", class="hl-string">"is_stp", class="hl-string">"stp"])),
    }


def add_internal_event(events: List[Dict[str, Any]], payment: Dict[str, Any], activity: str, timestamp_names: List[str], source_system: str, run_time: str) -> None:
    timestamp = first_value(payment, timestamp_names)
    event = base_event(payment, activity, timestamp, source_system, run_time)
    if event:
        events.append(event)


def extract_internal_events(payments: List[Dict[str, Any]], run_time: str) -> List[Dict[str, Any]]:
    events: List[Dict[str, Any]] = []
    for payment in payments:
        source_system = str(first_value(payment, [class="hl-string">"SourceSystem", class="hl-string">"source_system"], class="hl-string">"Internal Payment System"))
        add_internal_event(events, payment, class="hl-string">"Payment Request Created", [class="hl-string">"PaymentRequestCreatedTimestamp", class="hl-string">"payment_request_created_timestamp", class="hl-string">"created_at", class="hl-string">"creation_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Details Validated", [class="hl-string">"PaymentDetailsValidatedTimestamp", class="hl-string">"payment_details_validated_timestamp", class="hl-string">"validated_at", class="hl-string">"validation_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Sanctions Screening Passed", [class="hl-string">"SanctionsScreeningPassedTimestamp", class="hl-string">"sanctions_screening_passed_timestamp", class="hl-string">"screening_passed_at", class="hl-string">"screening_release_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Approved", [class="hl-string">"PaymentApprovedTimestamp", class="hl-string">"payment_approved_timestamp", class="hl-string">"approved_at", class="hl-string">"approval_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Instruction Sent", [class="hl-string">"PaymentInstructionSentTimestamp", class="hl-string">"payment_instruction_sent_timestamp", class="hl-string">"instruction_sent_at", class="hl-string">"swift_sent_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"SWIFT ACK Received", [class="hl-string">"SwiftAckReceivedTimestamp", class="hl-string">"swift_ack_received_timestamp", class="hl-string">"ack_received_at", class="hl-string">"swift_ack_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Error Identified", [class="hl-string">"PaymentErrorIdentifiedTimestamp", class="hl-string">"payment_error_identified_timestamp", class="hl-string">"error_identified_at", class="hl-string">"repair_queue_timestamp", class="hl-string">"exception_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Error Resolved", [class="hl-string">"PaymentErrorResolvedTimestamp", class="hl-string">"payment_error_resolved_timestamp", class="hl-string">"error_resolved_at", class="hl-string">"repair_resolved_timestamp", class="hl-string">"resubmission_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Rejected", [class="hl-string">"PaymentRejectedTimestamp", class="hl-string">"payment_rejected_timestamp", class="hl-string">"rejected_at", class="hl-string">"return_received_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Settled", [class="hl-string">"PaymentSettledTimestamp", class="hl-string">"payment_settled_timestamp", class="hl-string">"settled_at", class="hl-string">"beneficiary_credit_timestamp"], source_system, run_time)
        add_internal_event(events, payment, class="hl-string">"Payment Reconciled", [class="hl-string">"PaymentReconciledTimestamp", class="hl-string">"payment_reconciled_timestamp", class="hl-string">"reconciled_at", class="hl-string">"reconciliation_timestamp"], source_system, run_time)
    return events


def request_json(session: requests.Session, url: str, headers: Dict[str, str], params: Dict[str, Any]) -> Dict[str, Any]:
    last_error: Optional[Exception] = None
    for attempt in range(MAX_RETRIES):
        try:
            response = session.get(url, headers=headers, params=params, timeout=REQUEST_TIMEOUT_SECONDS)
            if response.status_code == 429 or response.status_code >= 500:
                response.raise_for_status()
            response.raise_for_status()
            return response.json()
        except (requests.RequestException, ValueError) as error:
            last_error = error
            if attempt == MAX_RETRIES - 1:
                break
            time.sleep(2 ** attempt)
    raise RuntimeError(fclass="hl-string">"SWIFT API request failed: {last_error}")


def get_items(payload: Dict[str, Any]) -> List[Dict[str, Any]]:
    for key in (class="hl-string">"events", class="hl-string">"statuses", class="hl-string">"statusEvents", class="hl-string">"data", class="hl-string">"items", class="hl-string">"results"):
        value = payload.get(key)
        if isinstance(value, list):
            return [item for item in value if isinstance(item, dict)]
    if isinstance(payload, list):
        return [item for item in payload if isinstance(item, dict)]
    return []


def fetch_gpi_events(uetr: str, session: requests.Session, raw_handle: Any, run_time: str) -> List[Dict[str, Any]]:
    url = SWIFT_API_BASE_URL.rstrip(class="hl-string">"/") + class="hl-string">"/" + SWIFT_API_PATH.lstrip(class="hl-string">"/")
    headers = {class="hl-string">"Accept": class="hl-string">"application/json", class="hl-string">"Authorization": fclass="hl-string">"Bearer {SWIFT_API_TOKEN}"}
    page = 1
    output: List[Dict[str, Any]] = []
    while True:
        params = {class="hl-string">"uetr": uetr, class="hl-string">"startDate": START_DATE, class="hl-string">"endDate": END_DATE, class="hl-string">"page": page, class="hl-string">"pageSize": PAGE_SIZE}
        payload = request_json(session, url, headers, params)
        raw_handle.write(json.dumps({class="hl-string">"run_time": run_time, class="hl-string">"uetr": uetr, class="hl-string">"request_params": params, class="hl-string">"response": payload}, default=str) + class="hl-string">"\n")
        items = get_items(payload)
        output.extend(items)
        has_next = first_value(payload, [class="hl-string">"hasNext", class="hl-string">"has_next", class="hl-string">"nextPage", class="hl-string">"next_page"])
        if not items or has_next in (False, None, class="hl-string">"false", class="hl-string">"False"):
            break
        if isinstance(has_next, (int, str)) and str(has_next).isdigit():
            page = int(has_next)
        else:
            page += 1
    return output


def tracker_event(payment: Dict[str, Any], tracker: Dict[str, Any], activity: str, run_time: str) -> Optional[Dict[str, Any]]:
    merged = dict(payment)
    merged.update({
        class="hl-string">"UniqueEndToEndReference": first_value(tracker, [class="hl-string">"uetr", class="hl-string">"UETR"], first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr"])),
        class="hl-string">"SwiftMessageType": first_value(tracker, [class="hl-string">"messageType", class="hl-string">"message_type", class="hl-string">"swiftMessageType"], first_value(payment, [class="hl-string">"SwiftMessageType", class="hl-string">"swift_message_type", class="hl-string">"message_type"])),
        class="hl-string">"BeneficiaryBic": first_value(tracker, [class="hl-string">"beneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"], first_value(payment, [class="hl-string">"BeneficiaryBic", class="hl-string">"beneficiary_bic", class="hl-string">"beneficiaryBIC"])),
        class="hl-string">"TransactionAmount": first_value(tracker, [class="hl-string">"amount", class="hl-string">"transactionAmount", class="hl-string">"transaction_amount"], first_value(payment, [class="hl-string">"TransactionAmount", class="hl-string">"transaction_amount", class="hl-string">"amount"])),
        class="hl-string">"TransactionCurrency": first_value(tracker, [class="hl-string">"currency", class="hl-string">"transactionCurrency", class="hl-string">"transaction_currency"], first_value(payment, [class="hl-string">"TransactionCurrency", class="hl-string">"transaction_currency", class="hl-string">"currency"])),
        class="hl-string">"ValueDate": first_value(tracker, [class="hl-string">"valueDate", class="hl-string">"value_date"], first_value(payment, [class="hl-string">"ValueDate", class="hl-string">"value_date"])),
        class="hl-string">"IsStp": first_value(tracker, [class="hl-string">"isStp", class="hl-string">"is_stp", class="hl-string">"stp"], first_value(payment, [class="hl-string">"IsStp", class="hl-string">"is_stp", class="hl-string">"stp"])),
        class="hl-string">"SwiftNakCode": first_value(tracker, [class="hl-string">"nakCode", class="hl-string">"nak_code", class="hl-string">"swiftNakCode"], first_value(payment, [class="hl-string">"SwiftNakCode", class="hl-string">"swift_nak_code", class="hl-string">"nak_code"])),
    })
    timestamp = first_value(tracker, [class="hl-string">"eventTimestamp", class="hl-string">"event_timestamp", class="hl-string">"timestamp", class="hl-string">"statusTimestamp", class="hl-string">"status_timestamp", class="hl-string">"occurredAt", class="hl-string">"occurred_at"])
    return base_event(merged, activity, timestamp, class="hl-string">"SWIFT gpi Tracker API", run_time)


def extract_tracker_events(payments: List[Dict[str, Any]], run_time: str, raw_handle: Any) -> List[Dict[str, Any]]:
    events: List[Dict[str, Any]] = []
    seen_uetrs = set()
    with requests.Session() as session:
        for payment in payments:
            uetr = first_value(payment, [class="hl-string">"UniqueEndToEndReference", class="hl-string">"UETR", class="hl-string">"uetr", class="hl-string">"uetr_value"])
            if not uetr or str(uetr) in seen_uetrs:
                continue
            seen_uetrs.add(str(uetr))
            for tracker in fetch_gpi_events(str(uetr), session, raw_handle, run_time):
                status = str(first_value(tracker, [class="hl-string">"status", class="hl-string">"statusCode", class="hl-string">"status_code", class="hl-string">"gpiStatus", class="hl-string">"gpi_status"], class="hl-string">"")).upper()
                activity = {class="hl-string">"ACSP": class="hl-string">"Payment Transferred", class="hl-string">"RJCT": class="hl-string">"Payment Rejected", class="hl-string">"ACSC": class="hl-string">"Payment Settled"}.get(status)
                if activity:
                    event = tracker_event(payment, tracker, activity, run_time)
                    if event:
                        events.append(event)
    return events


def deduplicate(events: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
    result: List[Dict[str, Any]] = []
    seen = set()
    for event in sorted(events, key=lambda row: (row[class="hl-string">"PaymentTransactionId"], row[class="hl-string">"EventTimestamp"], row[class="hl-string">"ActivityName"])):
        key = (event[class="hl-string">"PaymentTransactionId"], event[class="hl-string">"ActivityName"], event[class="hl-string">"EventTimestamp"], event.get(class="hl-string">"UniqueEndToEndReference"))
        if key not in seen:
            seen.add(key)
            result.append(event)
    return result


def write_csv(events: List[Dict[str, Any]], path: str) -> None:
    columns = REQUIRED_COLUMNS + RECOMMENDED_COLUMNS
    with open(path, class="hl-string">"w", encoding=class="hl-string">"utf-8", newline=class="hl-string">"") as handle:
        writer = csv.DictWriter(handle, fieldnames=columns, extrasaction=class="hl-string">"ignore")
        writer.writeheader()
        for event in events:
            writer.writerow({column: event.get(column) for column in columns})


def main() -> None:
    run_time = utc_now()
    payments = load_records(INTERNAL_EVENTS_FILE)
    if COMPANY_FILTER != class="hl-string">"[Configure based on your system]":
        payments = [payment for payment in payments if str(first_value(payment, [class="hl-string">"CompanyCode", class="hl-string">"company_code", class="hl-string">"Company", class="hl-string">"company"], class="hl-string">"")) == COMPANY_FILTER]
    internal_events = extract_internal_events(payments, run_time)
    with open(RAW_RESPONSE_FILE, class="hl-string">"w", encoding=class="hl-string">"utf-8") as raw_handle:
        tracker_events = extract_tracker_events(payments, run_time, raw_handle)
    events = deduplicate(internal_events + tracker_events)
    invalid = [event for event in events if any(event.get(column) in (None, class="hl-string">"") for column in REQUIRED_COLUMNS) or event[class="hl-string">"ActivityName"] not in ALL_ACTIVITIES]
    if invalid:
        raise ValueError(fclass="hl-string">"The extraction produced {len(invalid)} invalid event rows.")
    write_csv(events, OUTPUT_FILE)
    print(json.dumps({class="hl-string">"run_id": str(uuid.uuid4()), class="hl-string">"rows_written": len(events), class="hl-string">"output_file": OUTPUT_FILE, class="hl-string">"activities": sorted({event[class="hl-string">"ActivityName"] for event in events})}, indent=2))


if __name__ == class="hl-string">"__main__":
    main()

¿Todo listo para comenzar?

Aproveche estos Templates para convertir sus registros SWIFT sin procesar en una herramienta útil para mejorar las operaciones y agilizar la liquidación de pagos.

Volver a la guía de mejora

Descargar Template

Optimice ahora el procesamiento de sus pagos SWIFT

Alcance un 98 % de procesamiento directo y elimine los errores manuales

Comience la prueba gratuita

No se requiere tarjeta de crédito. Configuración en 5 minutos

Su Template de datos para el procesamiento de pagos

Su Template de datos para el procesamiento de pagos

Atributos del procesamiento de pagos

Actividades del procesamiento de pagos

Guías de extracción

Exportación del archivo de SWIFT Alliance Access

Pasos

Configuración

Consulta de ejemplo python

Analizador de Python para archivos SWIFT MT sin procesar

Pasos

Configuración

Consulta de ejemplo python

Conector de la API de SWIFT gpi

Pasos

Configuración

Consulta de ejemplo python

¿Todo listo para comenzar?

Optimice ahora el procesamiento de sus pagos SWIFT