> Melhoria contínua de processos > Processamento de pagamentos > SWIFT > Template de dados

Seu Template de dados de processamento de pagamentos

SWIFT

Atributos do processamento de pagamentos (19) Atividades do processamento de pagamentos (12) Guias de extração (3)

Seu Template de dados de processamento de pagamentos

Este Template oferece a estrutura necessária para mapear os fluxos de trabalho das transações SWIFT, da iniciação à liquidação final. Ele detalha os componentes de dados e os marcos operacionais necessários para dar visibilidade completa ao ciclo de vida dos pagamentos. Use este guia para preparar seus dados e revelar ineficiências ocultas e reduzir riscos de conformidade.

Atributos recomendados para uma análise detalhada das transações
Principais atividades e marcos do processo SWIFT
Orientações técnicas para extração de dados financeiros

Novidade em Event Logs? Saiba como criar um Event Log para Process Mining.

Baixar Template

Atributos do processamento de pagamentos

Estes são os campos de dados recomendados para incluir no Event Log e analisar de forma abrangente o ciclo de vida das transações SWIFT.

5 Obrigatório 9 Recomendado 5 Opcional

	Nome	Descrição
	ID da transação de pagamento PaymentTransactionId	Identificador exclusivo que representa o caso de pagamento de ponta a ponta.
Descrição Este atributo funciona como a chave central do caso no Process Mining. Ele agrupa todas as atividades relacionadas a uma única instrução de pagamento, da solicitação inicial à validação, transmissão SWIFT e liquidação final. Em contextos SWIFT, costuma ser associado ao Transaction Reference Number (TRN) ou ao Unique End-to-end Transaction Reference (UETR) para garantir a continuidade entre sistemas bancários. Ele é usado para reconstruir o caminho de cada instância do processo e é essencial para analisar variantes e calcular o tempo de ciclo. Por que isso importa A identificação exclusiva é a base do Process Mining, pois permite reunir eventos dispersos em uma visão integrada do processo. Onde encontrar Campo 20 (TRN) ou Campo 121 (UETR) da SWIFT nos cabeçalhos das mensagens. Exemplos TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	Nome da atividade ActivityName	Nome da etapa do processo ou do evento ocorrido.
Descrição Este atributo descreve a ação específica ou a mudança de status registrada no log do sistema. Alguns exemplos são 'Solicitação de pagamento criada', 'Triagem de sanções aprovada' e 'ACK SWIFT recebido'. É a principal dimensão dos mapas de processo: define os nós da visualização e ajuda os analistas a entender a sequência de operações realizadas em um pagamento. Por que isso importa Define o que acontece no processo e permite visualizar o fluxo e suas variações. Onde encontrar Logs de transações, registros de auditoria ou dados derivados de tipos de mensagem, como MT103 enviada. Exemplos Solicitação de pagamento criadaInstrução de pagamento enviadaACK SWIFT recebidoPagamento aprovado
	Registro de data e hora do evento EventTimestamp	Data e hora exatas em que a atividade ocorreu.
Descrição Este atributo registra o momento exato em que um evento aconteceu. Ele é usado para ordenar as atividades cronologicamente e calcular todas as métricas baseadas em duração, como tempo de atravessamento, tempo de ciclo e volume processado. Registros de data e hora precisos são essenciais para analisar a 'Performance em relação aos horários-limite da rede' e identificar gargalos na cadeia de aprovação. Por que isso importa Os registros de data e hora são a base de todas as análises temporais e métricas de performance no Process Mining. Onde encontrar Logs de auditoria do sistema, registros de data e hora de criação de mensagens ou horários de transações no banco de dados. Exemplos 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	Sistema de origem SourceSystem	Nome do sistema de onde vieram os dados do evento.
Descrição Identifica o software ou a plataforma que gerou o Event Log. Em um processo de pagamento, pode ser o sistema bancário central, o gateway de pagamentos ou a própria interface SWIFT. Este atributo ajuda a verificar a linhagem dos dados e a investigar problemas ao combinar dados de diferentes aplicativos bancários. Por que isso importa Dá contexto sobre a origem dos dados, essencial para o Process Mining em vários sistemas. Onde encontrar Definido diretamente durante o ETL ou extraído dos identificadores do sistema. Exemplos SWIFT Alliance AccessCore Banking SystemPayment EngineFiltro de sanções
	Última atualização dos dados LastDataUpdate	Registro de data e hora da última extração ou atualização do registro.
Descrição Indica quando os dados foram carregados pela última vez na ferramenta de Process Mining. Essa informação é essencial para avaliar a atualização dos dados e garantir que os Dashboards reflitam o estado mais recente das operações de pagamento. Ela ajuda as pessoas a confiar nos dados, mostrando com transparência a latência do fluxo de geração de relatórios. Por que isso importa Ajuda as pessoas a entender a atualidade e a confiabilidade dos dados apresentados. Onde encontrar Registro de data e hora da execução do processo ETL. Exemplos 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	BIC do beneficiário BeneficiaryBic	Código de identificação bancária da instituição recebedora.
Descrição Identifica o banco de destino do pagamento. Essa dimensão é fundamental para o Dashboard "Causa raiz das rejeições do beneficiário". Ao agrupar as falhas pelo BIC do beneficiário, o banco pode identificar contrapartes específicas que rejeitam instruções com frequência por problemas na qualidade dos dados ou por requisitos de formatação específicos. Por que isso importa Essencial para analisar a performance das contrapartes e os padrões de rejeição. Onde encontrar Campo 57A (instituição junto à qual está a conta) ou 58A (instituição do beneficiário) do SWIFT. Exemplos CITIUS33BARCGB22DRESDEFFHANDSEXX
	Código NAK do SWIFT SwiftNakCode	Código de erro retornado pela rede SWIFT quando uma mensagem é rejeitada.
Descrição Contém o código de erro específico (por exemplo, T26, T13) informado em uma confirmação negativa (NAK) da rede SWIFT. Esse atributo alimenta o Dashboard "Análise de erros e retrabalho do SWIFT", permitindo categorizar falhas técnicas e priorizar correções no sistema. Por que isso importa Aponta as causas técnicas das rejeições na rede. Onde encontrar Mensagens de sistema MT 015/019 ou campo 451 em ACK/NAK. Exemplos T26H01T13G02
	Data-valor ValueDate	Data em que os fundos devem ficar disponíveis para o beneficiário.
Descrição Representa a data de liquidação indicada na mensagem de pagamento. Comparar essa data com o registro de data e hora de "Pagamento liquidado" ajuda na análise do Dashboard "Envelhecimento da liquidação e da conciliação". Ela indica a urgência do pagamento e é usada para medir o cumprimento dos acordos de nível de serviço relativos à disponibilidade dos fundos. Por que isso importa Essencial para a gestão de liquidez e para medir a pontualidade da liquidação. Onde encontrar Campo 32A do SWIFT MT (subcampo de data) ou IntrBkSttlmDt do ISO 20022. Exemplos 2023-10-262023-11-01
	É STP IsStp	Indicador que mostra se o pagamento exigiu intervenção manual.
Descrição Indicador booleano que recebe o valor True quando o caso não contém atividades de "Erro identificado", "Pagamento rejeitado" ou "Modificação" manual. Ele calcula diretamente o KPI "Taxa de processamento direto". É a principal métrica para avaliar o sucesso da automação no processamento de pagamentos. Por que isso importa Principal medida da eficiência do processo e da saúde da automação. Onde encontrar Calculado com base na ausência de atividades negativas ou manuais específicas no caso. Exemplos truefalse
	Moeda da transação TransactionCurrency	Código ISO de 3 letras que indica a moeda do pagamento.
Descrição Identifica a moeda em que o pagamento é denominado (por exemplo, USD, EUR, GBP). Esse dado é essencial para o Dashboard "Performance do horário limite da rede", pois os horários limite variam conforme a moeda. Também permite analisar a "Eficiência da conversão de moedas", identificando pares de moedas diferentes. Por que isso importa Define regras de roteamento, horários limite e corredores de liquidação. Onde encontrar Campo 32A (moeda) do SWIFT MT ou elemento Ccy do ISO 20022. Exemplos USDEURGBPJPY
	Tipo de mensagem SWIFT SwiftMessageType	Tipo de mensagem SWIFT usado (por exemplo, MT103, pacs.008).
Descrição Indica o formato específico da instrução de pagamento. Entre os tipos mais comuns estão MT103, para transferências de clientes, e os equivalentes no ISO 20022, como pacs.008. É usado na análise "Variantes da jornada de pagamento" para comparar a eficiência de processamento dos formatos MT legados com os novos padrões ISO. Por que isso importa Diferencia os fluxos de pagamento e os padrões de processamento (legado ou ISO 20022). Onde encontrar Bloco 2 do SWIFT (cabeçalho da aplicação), campo Tipo de mensagem. Exemplos MT103MT202pacs.008MT101
	UETR UniqueEndToEndReference	Referência única de ponta a ponta da transação, usada para rastreamento no SWIFT gpi.
Descrição O UETR é uma sequência de 36 caracteres que fornece uma referência única e imutável para um pagamento em toda a rede SWIFT. Ao contrário dos IDs internos, o UETR permanece o mesmo entre os bancos. Esse atributo é essencial para ter visibilidade de ponta a ponta e correlacionar registros internos com atualizações externas de status do SWIFT gpi. Por que isso importa O padrão de referência para rastrear pagamentos internacionais entre diferentes instituições. Onde encontrar Bloco 3 do SWIFT, campo 121. Exemplos b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Usuário de processamento ProcessingUser	Usuário ou agente do sistema que realizou a atividade.
Descrição Identifica a pessoa ou o bot automatizado responsável pela atividade, como um analista de conformidade que aprova uma ocorrência de sanção ou um operador que corrige um erro de formatação. Esse atributo alimenta o Dashboard "Mapa de calor de erros de validação", ajudando gestores a identificar necessidades de treinamento ou usuários específicos associados a altas taxas de retrabalho. Por que isso importa Permite analisar os recursos e identificar gargalos manuais. Onde encontrar Registros de auditoria do sistema, coluna "ID do usuário" nas tabelas de transações. Exemplos SISTEMAJ.DoeCompliance_Bot_01M.Smith
	Valor da transação TransactionAmount	Valor monetário da instrução de pagamento.
Descrição Representa o valor principal transferido. Esses dados são extraídos de campos específicos da SWIFT, como o Campo 32A da MT103. São essenciais para o Dashboard 'Ciclos de aprovação de transferências de alto valor', pois permitem segmentar os pagamentos por valor e analisar atrasos na aprovação de transações de alto risco e alto valor. Por que isso importa Permite analisar o impacto financeiro e segmentar as transações por valor. Onde encontrar Campo 32A (valor) da SWIFT MT ou elemento IntrBkSttlmAmt da ISO 20022. Exemplos 15000.001250.501000000.0045.00
	Cumpriu o horário limite MetCutOffTime	Indicador que mostra se a instrução foi enviada antes do prazo da rede.
Descrição Indicador booleano calculado pela comparação entre o horário de envio da instrução de pagamento e o horário limite da rede SWIFT para a moeda correspondente. Esse dado permite calcular o KPI "Taxa de cumprimento do horário limite do SWIFT". O não cumprimento do horário limite atrasa a liquidação e afeta as posições de liquidez. Por que isso importa KPI operacional essencial para a gestão de tesouraria e liquidez. Onde encontrar Calculado pela comparação do registro de data e hora com uma tabela de referência estática de horários limite. Exemplos truefalse
	É internacional IsCrossBorder	Indicador que mostra se o pagamento envolve países diferentes.
Descrição Atributo booleano que recebe o valor True quando o país do remetente é diferente do país do beneficiário. Esse dado permite calcular o KPI "Latência no processamento de várias moedas", separando os fluxos nacionais dos internacionais. Pagamentos internacionais costumam ter mais complexidade, custos e tempo de processamento. Por que isso importa Segmentação fundamental para analisar a complexidade dos pagamentos. Onde encontrar Comparação entre o código do país no BIC do remetente e o código do país no BIC do beneficiário. Exemplos truefalse
	Motivo da rejeição RejectionReason	Descrição em texto que explica por que um pagamento foi rejeitado.
Descrição Contém a descrição narrativa ou do código da falha de um pagamento, geralmente encontrada no campo 72 do SWIFT (informações do remetente para o destinatário) ou em mensagens de devolução. Esse dado permite analisar a "Causa raiz das rejeições do beneficiário". Ele permite que analistas façam mineração de texto para identificar temas recorrentes nas rejeições (por exemplo, "Conta inválida", "Nome do beneficiário divergente"). Por que isso importa Fornece contexto qualitativo para as falhas do processo. Onde encontrar Campo 72 ou 79 do SWIFT em mensagens de devolução (devolução MT103). Exemplos Conta do beneficiário encerradaIBAN inválidoFalha de conformidade regulatóriaCódigo do banco desconhecido
	País de origem OriginatingCountry	Código do país da entidade que inicia o pagamento.
Descrição Indica a jurisdição de origem da solicitação de pagamento. Esse dado é essencial para o Dashboard "Tempo de processamento da triagem de sanções", pois pagamentos originados em jurisdições de alto risco costumam passar por verificações de conformidade mais rigorosas e demoradas. Também permite analisar geograficamente os volumes de pagamento e os atrasos no processamento. Por que isso importa Dimensão importante para analisar riscos de conformidade e a performance regional. Onde encontrar Derivado do BIC do remetente (caracteres 5 e 6 do código do país). Exemplos USGBDEFR
	Prioridade da instrução InstructionPriority	Indicador de prioridade que mostra a urgência do pagamento.
Descrição Derivada dos cabeçalhos da mensagem (por exemplo, "Normal" ou "Urgente"). Permite segmentar os dados no Dashboard "Ciclos de aprovação de transferências de alto valor", pois pagamentos urgentes costumam exigir fluxos de aprovação acelerados. Entender a distribuição das prioridades ajuda a planejar os recursos nos períodos de pico. Por que isso importa Ajuda a diferenciar os requisitos de SLA para pagamentos padrão e acelerados. Onde encontrar Bloco 2 do SWIFT, campo Prioridade da mensagem (por exemplo, N para Normal, U para Urgente). Exemplos NormalUrgenteSistema

Obrigatório Recomendado Opcional

Atividades do processamento de pagamentos

Estas são as principais etapas e marcos do processo que você deve registrar no Event Log para descobrir o processo com precisão e identificar gargalos.

6 Recomendado 6 Opcional

	Atividade	Descrição
	Instrução de pagamento enviada	Transmissão da mensagem formatada (MT103 ou ISO 20022 pacs.008) para o SWIFT Gateway. O evento é registrado explicitamente quando o conteúdo da mensagem é gerado e transferido para a interface da rede.
Por que isso importa Usado para calcular a 'Taxa de cumprimento dos horários-limite SWIFT'. Marca a transição do processamento interno para o processamento na rede. Onde encontrar Logs do SWIFT Alliance Access (SAA) ou logs de transmissão do Gateway. Coleta Registrado quando a mensagem é enviada Tipo de evento explicit
	Pagamento aprovado	Ação final de autorização realizada por um responsável designado ou por uma regra automatizada para transferências de alto valor. O evento é registrado explicitamente quando o sinalizador do fluxo de trabalho de aprovação é definido como verdadeiro.
Por que isso importa Essencial para o Dashboard 'Ciclos de aprovação de transferências de alto valor'. Identifica atrasos nas aprovações manuais de grandes movimentações de liquidez. Onde encontrar Registro de auditoria do mecanismo do fluxo de trabalho de aprovação. Coleta Registrado quando a ação de aprovação é executada Tipo de evento explicit
	Pagamento conciliado	Conciliação da transação de pagamento com o extrato contábil da conta Nostro/Vostro. O evento é identificado quando o sistema de conciliação associa o ID da transação a uma linha do extrato.
Por que isso importa Conclui o ciclo financeiro. Atrasos nesta etapa afetam a visibilidade do caixa e a capacidade de auditoria. Onde encontrar Logs do sistema de conciliação ou status 'Conciliado' no Core Banking System. Coleta Compare o status da conciliação Tipo de evento inferred
	Pagamento liquidado	Confirmação de que os recursos foram creditados na conta do beneficiário, geralmente indicada pelo status gpi ACSC. O evento é registrado explicitamente por meio de atualizações do Tracker ou mensagens de confirmação.
Por que isso importa Representa a conclusão efetiva da cadeia de pagamento. É essencial para calcular a 'Diferença entre liquidação e conciliação'. Onde encontrar SWIFT gpi Tracker (status ACSC) ou confirmações MT900/910. Coleta Registrado quando a liquidação é confirmada Tipo de evento explicit
	Solicitação de pagamento criada	Geração inicial da instrução de pagamento no sistema bancário interno ou ERP. Esse evento é registrado explicitamente quando uma referência exclusiva de transação (TRN ou UETR) é atribuída pela primeira vez à ordem de pagamento.
Por que isso importa Define o horário de início de todo o ciclo de vida do pagamento. É essencial para calcular os tempos de processamento de ponta a ponta e identificar atrasos nas etapas anteriores ao uso da rede SWIFT. Onde encontrar Registro de data e hora da criação da tabela de transações no Core Banking System (CBS) ou no Payment Hub. Coleta Registrado quando o registro da transação é criado Tipo de evento explicit
	Triagem de sanções aprovada	Registro de data e hora em que a instrução de pagamento é aprovada na triagem das listas da OFAC e de sanções. O evento é registrado explicitamente nos logs do sistema de conformidade ou identificado quando o status 'Retido na triagem' é liberado.
Por que isso importa Essencial para o Dashboard 'Tempo de atravessamento da triagem de sanções'. Atrasos nesta etapa indicam gargalos de conformidade, não ineficiências operacionais. Onde encontrar Logs do sistema de filtragem de conformidade ou sinalizadores de status de conformidade do Payment Hub. Coleta Registrado quando o status da triagem é atualizado Tipo de evento explicit
	ACK SWIFT recebido	Recebimento de uma confirmação técnica (ACK) da rede SWIFT, indicando que a mensagem foi aceita para processamento. O evento é registrado explicitamente nos logs da interface da rede.
Por que isso importa Confirma que a mensagem entrou corretamente na rede global. Permite diferenciar falhas internas de problemas na transmissão pela rede. Onde encontrar Logs do SWIFT Gateway, verificando os sinais ACK e NACK. Coleta Registrado quando o ACK da rede é recebido Tipo de evento explicit
	Dados do pagamento validados	Conclusão bem-sucedida das verificações de sintaxe e formato da instrução de pagamento, como o formato do IBAN e a validade do BIC. Muitas vezes, esse evento é identificado quando o status da transação muda de 'Rascunho' para 'Validado' ou 'Pronto para autorização'.
Por que isso importa Uma taxa elevada de falhas nesta etapa indica baixa qualidade dos dados na origem. Mede o KPI de 'Aprovação na primeira validação'. Onde encontrar Logs de status do Payment Engine ou tabelas de histórico de validação. Coleta Compare o campo de status antes e depois Tipo de evento inferred
	Erro no pagamento identificado	Evento em que uma transação é sinalizada para correção devido a falhas de validação, NACKs ou mensagens de rejeição. É identificado quando a transação entra em uma fila de 'Correção', 'Ajuste' ou 'Exceção'.
Por que isso importa Acompanha a 'Taxa de retrabalho na resolução de erros'. Uma frequência elevada nesta etapa reduz os índices de processamento direto (STP). Onde encontrar Colunas de status do Payment Hub ou logs da fila de exceções. Coleta Compare o campo de status com Erro/Correção Tipo de evento inferred
	Erro no pagamento resolvido	Alteração e reenvio bem-sucedidos de uma transação que estava com erro. O evento é identificado quando a transação sai da fila de 'Correção' e volta ao status 'Em processamento' ou 'Pronto'.
Por que isso importa Mede a eficiência da equipe de retrabalho manual. Durações longas nesta etapa podem indicar lacunas de treinamento ou códigos de erro complexos. Onde encontrar Logs de status do Payment Hub que mostram a saída das filas de exceção. Coleta Compare o campo de status na saída da fila de correção Tipo de evento inferred
	Pagamento rejeitado	Recebimento de uma mensagem de rejeição (devolução MT103 ou status gpi RJCT) de um banco beneficiário ou intermediário. O evento é registrado explicitamente nas mensagens SWIFT recebidas.
Por que isso importa Essencial para o Dashboard 'Causa raiz das rejeições de beneficiários'. Identifica impedimentos externos, como contas encerradas ou dados de roteamento incorretos. Onde encontrar Mensagens SWIFT recebidas (MT103 RET, pacs.004) ou status gpi RJCT. Coleta Registrado quando a mensagem de rejeição é recebida Tipo de evento explicit
	Pagamento transferido	Atualização intermediária de status, geralmente o status gpi ACSP, que indica que um banco intermediário está processando o pagamento. O evento é registrado por meio de atualizações do SWIFT gpi Tracker ou de mensagens de status.
Por que isso importa Dá visibilidade ao que acontece nas etapas intermediárias do banco correspondente. É essencial para analisar toda a jornada de ponta a ponta. Onde encontrar Feeds de dados do SWIFT gpi Tracker ou mensagens MT199/trck. Coleta Registrado quando a atualização do Tracker é recebida Tipo de evento explicit

Recomendado Opcional

Guias de extração

Como obter seus dados do SWIFT

Etapas

Acesse o SWIFT Alliance WebPlatform ou a interface gráfica do Alliance Access com uma conta de administrador que tenha acesso às configurações de arquivamento.
No menu System Management, selecione Archiving e, em seguida, Automated Archiving Configuration.
Configure um novo perfil de exportação diária. Defina Target Directory como um caminho de rede seguro, acessível pelos seus scripts de extração.
Especifique o escopo do conteúdo: selecione 'Messages' e marque 'Include History' e 'Include Interventions'. Isso é essencial para registrar eventos da trilha de auditoria, como aprovações e validações.
Selecione o formato de saída. Escolha XML (especificamente 'SAA XML v2' ou o esquema mais recente disponível), pois ele preserva melhor do que CSV a relação hierárquica entre o cabeçalho da mensagem e os eventos do histórico.
Defina os filtros de período para extrair o histórico necessário à iniciativa de Process Mining ou configure a execução diária para obter os dados de T-1.
Execute manualmente a tarefa de exportação do arquivo para a carga inicial ou aguarde a conclusão da tarefa em lote agendada. Verifique se os arquivos .xml foram gerados no diretório de destino.
Como a exportação do SAA é um arquivo XML hierárquico e o ProcessMind exige um Event Log CSV plano, execute um script de transformação. Use o script Python fornecido na seção Query para analisar o XML.
O script percorre cada elemento de mensagem. Ele extrai a referência única de transação ponta a ponta (UETR) ou o número de referência da transação (TRN) para usar como ID do caso.
Em seguida, o script percorre os nós filhos 'History' e 'Intervention' de cada mensagem para gerar linhas de atividade. Ele associa os códigos de status internos do SAA (por exemplo, 'NetworkAck', 'Authorisation') aos nomes de atividade padronizados.
Execute o script Python nos arquivos XML exportados para gerar o arquivo plano 'events.csv'.
Valide o CSV para garantir que colunas como EventTimestamp estejam no formato ISO 8601 e carregue o arquivo no ProcessMind.

Configuração

Formato do arquivo: XML (preferencial) ou CSV (arquivo plano). O XML é altamente recomendado para registrar nós de histórico aninhados.
Incluir texto da mensagem: Sim (necessário para analisar valores, moedas e dados do beneficiário).
Incluir histórico/intervenções: Sim (obrigatório para identificar aprovações, validações e erros).
Período: Configure uma janela móvel (por exemplo, últimos 30 dias) para cargas incrementais ou datas fixas para o histórico inicial.
Tipos de mensagem: Filtre por MT103, MT202, pacs.008, pacs.009 e pacs.004/002 (para devoluções/status).
Direções: Inclua entradas (emissão) e saídas (recepção) para registrar rejeições ou confirmações recebidas.
Segurança: Garanta que a pasta de exportação tenha permissões rigorosas de leitura e gravação, pois esses arquivos contêm dados de pagamentos ativos.

a Consulta de exemplo 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}")

Etapas

Prepare o ambiente: Verifique se o Python 3.8 ou superior está instalado no servidor de extração. Instale as bibliotecas necessárias com pip (pandas, numpy). Crie um diretório de trabalho dedicado com uma subpasta chamada raw_swift_files e coloque nela todos os arquivos diários .out, .txt ou .fin.
Entenda a estrutura dos arquivos: As mensagens SWIFT FIN brutas são organizadas em blocos ({1: Header} {2: Application} {4: Body}). Identifique os delimitadores. Os arquivos padrão usam chaves. Verifique se os arquivos não estão envolvidos em envelopes proprietários (como cabeçalhos RJE) ou remova esses envelopes antes do processamento.
Configure os caminhos do script: Abra o script Python fornecido. Atualize a variável INPUT_DIRECTORY para apontar para a pasta raw_swift_files. Atualize o caminho de OUTPUT_FILE para o CSV resultante.
Defina os padrões de regex: O script usa regex para isolar os blocos. O bloco 1 contém o BIC do remetente e o número de sequência. O bloco 2 contém o tipo de mensagem (por exemplo, I103, O103) e o BIC do destinatário. O bloco 4 contém as tags de dados comerciais (por exemplo, :20: TRN, :32A: valor/quantia).
Associe tipos de mensagem a atividades: O script contém um dicionário de associações. MT103 indica 'Payment Instruction Sent'. MT012 (System ACK) indica 'SWIFT ACK Received'. MT900/910 indica 'Payment Settled'. MT199/299 com códigos de status específicos (ACSP, RJCT) é associado a 'Payment Transferred' ou 'Payment Rejected'.
Extraia atributos: O analisador percorre tags específicas. :20: é associado a Payment Transaction ID. :121: é associado a UETR. :32A: é analisado em data, moeda e valor.
Trate estados internos: Para atividades como 'Payment Request Created' ou 'Payment Approved', que costumam ser eventos internos do ERP e não aparecem nos arquivos SWIFT, o script deriva esses dados do timestamp de criação da mensagem no bloco 1, se não houver registros explícitos, ou procura códigos de texto específicos no campo :72: (Sender to Receiver Info), caso sua organização registre as aprovações nesse campo.
Execute a extração: Execute o script pela linha de comando: python swift_parser.py. O script percorre todos os arquivos, analisa os blocos SWIFT válidos e ignora linhas malformadas.
Valide após o processamento: Abra o CSV gerado. Verifique o formato de EventTimestamp (recomenda-se ISO 8601). Confirme se PaymentTransactionId está preenchido em todas as linhas para permitir o agrupamento por caso.
Transforme os dados: Se 'ValueDate' estiver no formato YYMMDD, o script o converte para YYYY-MM-DD. Padronize os separadores decimais em 'TransactionAmount' (ponto ou vírgula).
Faça a revisão final: Filtre por um UETR específico para ver o fluxo completo, de Instruction Sent a ACK e Settlement. Verifique se os NAKs (MT019) aparecem como 'Payment Error Identified'.
Carregue no ProcessMind: Importe o CSV. Associe PaymentTransactionId a ID do caso, ActivityName a Atividade e EventTimestamp a Timestamp.

Configuração

Diretório de entrada: Caminho para a pasta que contém os arquivos planos FIN/MT brutos. Verifique se há permissões de leitura.
Interpretação do formato de data: As datas SWIFT brutas usam YYMMDD. O script considera o século como 20xx.
Filtros de tipo de mensagem: O script se concentra nas categorias 1 (pagamentos), 9 (extratos) e nas mensagens de sistema mais comuns (012, 019). Ajuste a lista RELEVANT_MT_TYPES se precisar da categoria 2 (transferências entre instituições financeiras).
Codificação: O padrão é 'utf-8'. Altere para 'latin-1' ou 'ascii' se os arquivos contiverem caracteres de codificação legada.
Processamento em lote: Para conjuntos de dados com mais de 1 GB, o script usa uma abordagem com gerador para evitar estouro de memória e processa um arquivo por vez.
Ajuste de regex: A regex estrita pressupõe o formato FIN padrão {1:...}{2:...}{4:...}. Se os arquivos usarem $ ou outros delimitadores, atualize a variável BLOCK_PATTERN.

a Consulta de exemplo 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()

Etapas

Confirme se você tem uma assinatura da API SWIFT gpi Tracker, credenciais de API, capacidade de pesquisa por UETR e acesso à fonte de eventos do sistema interno de pagamentos. Consulte a documentação do serviço SWIFT para obter a URL base exata da API, o método de autenticação, o esquema de resposta, os limites de requisições e as regras de paginação. Não presuma o caminho de um endpoint, pois ele depende do serviço SWIFT licenciado e da implantação.
Configure o script com a string de conexão, as credenciais, o período e os filtros específicos da empresa necessários. Use um período de três a seis meses para a extração inicial. Restrinja os dados da fonte interna às transações de pagamento que tenham TRN ou UETR e mantenha o nome do sistema de origem em cada evento.
Extraia os eventos internos do ciclo de vida: Payment Request Created, Payment Details Validated, Sanctions Screening Passed, Payment Approved, Payment Instruction Sent, SWIFT ACK Received, Payment Error Identified, Payment Error Resolved, Payment Rejected, Payment Settled e Payment Reconciled. Converta cada evento de origem em uma linha separada do Event Log. Não espere que o ProcessMind deduza atividades.
Extraia os UETRs dos registros internos de pagamento e consulte a API licenciada do SWIFT gpi Tracker para cada UETR. Use a documentação da API fornecida para seu ambiente para configurar a URL da solicitação, os cabeçalhos de autenticação, os parâmetros, a paginação e os campos de resposta. Armazene a resposta bruta para fins de auditoria.
Converta os status aplicáveis do gpi Tracker em linhas de evento explícitas. O script associa ACSP a Payment Transferred, RJCT a Payment Rejected e ACSC a Payment Settled. Se a resposta licenciada usar outros nomes de status ou timestamps, atualize as associações com base no esquema de resposta documentado. Não crie um evento quando a API não fornecer a ocorrência de status correspondente.
Normalize todos os timestamps para um fuso horário consistente, de preferência UTC, mantendo o timestamp original quando necessário para auditoria. Converta valores monetários em números, preserve a moeda da transação, normalize os valores booleanos de STP e mantenha valores NULL quando a fonte não fornecer um atributo.
Remova eventos duplicados usando PaymentTransactionId, ActivityName, EventTimestamp e o identificador de evento de origem mais específico disponível. Preserve ocorrências legítimas múltiplas, como ciclos repetidos de correção e reenvio, a menos que a regra de negócio exija explicitamente uma única ocorrência por atividade.
Valide se cada linha de saída contém PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem e LastDataUpdate. Confirme se ActivityName contém apenas os valores de atividade documentados e se todas as 12 atividades estão representadas quando presentes nos dados de origem.
Exporte o conjunto de dados resultante como CSV UTF-8 ou em outro formato de Event Log compatível com o ProcessMind. Use uma linha por evento, inclua as colunas obrigatórias e recomendadas e associe PaymentTransactionId ao identificador do caso, ActivityName à atividade e EventTimestamp ao timestamp do evento. Carregue o arquivo no ProcessMind sem esperar que eventos adicionais sejam derivados.

Configuração

Endpoint e esquema da API: Configure a URL base exata da API SWIFT gpi Tracker, o caminho do recurso, os parâmetros da solicitação, os cabeçalhos de autenticação, a paginação e os nomes dos campos de resposta conforme a documentação licenciada do SWIFT para seu ambiente. O script não inventa um endpoint.
Credenciais e autorização: Use o mecanismo aprovado de credenciais da API SWIFT, os requisitos de certificado ou token, o método de armazenamento de segredos e as autorizações do sistema de origem interno. Não inclua segredos de produção diretamente no código-fonte.
Período: Comece com três a seis meses. Use o timestamp do evento ou a data de criação do pagamento, conforme o objetivo do relatório. Para grandes volumes, processe períodos menores e registre pontos de controle para os UETRs concluídos.
Filtros da fonte interna: Configure filtros de empresa, entidade legal, filial, produto de pagamento, tipo de documento, tipo de mensagem, moeda e status conforme seu sistema. Use marcadores como [Configure based on your system] até confirmar o esquema da fonte.
Associação de atividades: Mantenha associações explícitas para status e filas internas. Exemplos: Draft para Validated ou Ready for Auth em Payment Details Validated; liberação de Screening Hold em Sanctions Screening Passed; entrada na fila Repair ou Exception em Payment Error Identified; retorno a Processing ou Ready for Payment em Payment Error Resolved.
Associação de status do gpi: Associe os status documentados do Tracker a atividades explícitas. Esta implementação associa ACSP a Payment Transferred, RJCT a Payment Rejected e ACSC a Payment Settled. Amplie as associações somente quando a documentação da API licenciada confirmar o significado dos status.
Política de timestamp: Normalize os timestamps para UTC sempre que possível. Defina a prioridade entre o horário do evento de origem, o horário do evento do Tracker, o horário de recebimento da mensagem e o horário da extração. LastDataUpdate deve representar o horário da extração ou atualização, não o horário do evento de negócio.
Limites de requisições e novas tentativas: Configure o tempo limite das solicitações, o número de novas tentativas, o intervalo exponencial, o tratamento de status HTTP e a paginação. Respeite os limites do serviço SWIFT e evite solicitações paralelas sem controle.
Performance: Armazene respostas em cache por UETR, processe UETRs em lotes, registre pontos de controle e use extração incremental quando disponível. Evite consultar o Tracker repetidamente para o mesmo UETR e período.
Qualidade dos dados: Exija PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem e LastDataUpdate. Permita valores NULL para atributos recomendados quando a fonte não os fornecer, mas informe as taxas de preenchimento.
Auditabilidade: Armazene a resposta bruta da API, o horário da solicitação, o status da resposta, o UETR e o identificador da execução da extração em um local de auditoria aprovado. Aplique as regras de retenção e segurança exigidas para dados de pagamento.
Pré-requisitos: Confirme o acesso aos registros do ciclo de vida de pagamentos internos, conformidade, gateway SWIFT, conciliação e interface de mensagens, além da licença da API SWIFT gpi Tracker e dos certificados ou das autorizações de rede necessários.

a Consulta de exemplo 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()

Pronto para começar?

Use estes Templates para transformar seus registros brutos do SWIFT em uma ferramenta para melhorar as operações e acelerar a liquidação de pagamentos.

Voltar ao guia de melhoria Baixar Template

Otimize agora o processamento de pagamentos SWIFT

Alcance 98% de processamento direto e elimine erros manuais

Comece o teste grátis

Não é necessário cartão de crédito. Configuração em 5 minutos

Seu Template de dados de processamento de pagamentos

Seu Template de dados de processamento de pagamentos

Atributos do processamento de pagamentos

Atividades do processamento de pagamentos

Guias de extração

Exportação de arquivo do SWIFT Alliance Access

Etapas

Configuração

a Consulta de exemplo python

Analisador Python para arquivos SWIFT MT brutos

Etapas

Configuração

a Consulta de exemplo python

Conector da API SWIFT gpi

Etapas

Configuração

a Consulta de exemplo python

Pronto para começar?

Otimize agora o processamento de pagamentos SWIFT

Seu Template de dados de processamento de pagamentos

Seu Template de dados de processamento de pagamentos

Atributos do processamento de pagamentos

Atividades do processamento de pagamentos

Guias de extração

Exportação de arquivo do SWIFT Alliance Access

Etapas

Configuração

a Consulta de exemplo python

Analisador Python para arquivos SWIFT MT brutos

Etapas

Configuração

a Consulta de exemplo python

Conector da API SWIFT gpi

Etapas

Configuração

a Consulta de exemplo python

Pronto para começar?

Otimize agora o processamento de pagamentos SWIFT

Sua privacidade é importante para nós