> Melhoria Contínua de Processos > Pagamentos em Processamento > SWIFT > Modelo de Dados

Seu Template de Dados para Processamento de Pagamentos

SWIFT

Atributos de Processamento de Pagamentos (20) Atividades de Processamento de Pagamentos (12) Guias de Extração (3)

Seu Template de Dados para Processamento de Pagamentos

Este template oferece a base estrutural para mapear seus workflows de transações SWIFT, do início à liquidação final. Ele detalha os componentes de dados e marcos operacionais necessários para obter visibilidade total dos ciclos de pagamento. Com este guia, você pode preparar seus dados para revelar ineficiências ocultas e reduzir riscos de conformidade.

Atributos recomendados para análise profunda de transações
Atividades principais e marcos do processo SWIFT
Orientação técnica para extração de dados financeiros

É novo em event logs? Saiba como criar um event log para Process Mining.

Baixar Modelo

Atributos de Processamento de Pagamentos

Estes são os campos de dados recomendados para incluir no seu log de eventos para uma análise completa do ciclo de vida das transações SWIFT.

5 Obrigatório 9 Recomendado 6 Opcional

	Nome	Descrição
	Event Timestamp EventTimestamp	A data e hora exatas em que a atividade ocorreu.
Descrição Este atributo registra o momento preciso em que um evento ocorreu. É usado para sequenciar atividades cronologicamente e calcular métricas de duração, como lead times, tempos de ciclo e vazão. Timestamps precisos são cruciais para analisar o desempenho em relação aos horários limite (cut-off times) e identificar gargalos na cadeia de aprovação. Por que é importante Os timestamps são a base para todas as análises temporais e métricas de desempenho em Process Mining. Onde obter Logs de auditoria do sistema, timestamps de criação de mensagem ou tempos de transação do banco de dados. Exemplos 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	ID da Transação de Pagamento PaymentTransactionId	O identificador único que representa o caso de pagamento de ponta a ponta.
Descrição Este atributo serve como a chave de caso central para o Process Mining. Ele agrupa todas as atividades ligadas a uma única instrução de pagamento, da solicitação inicial à liquidação final. Em contextos SWIFT, costuma ser mapeado para o TRN ou UETR para garantir a continuidade entre os sistemas bancários. É usado para reconstruir o caminho da instância do processo e é essencial para análises de variantes e cálculos de tempo de ciclo. Por que é importante A identificação única é a base do Process Mining, permitindo a união de eventos dispersos em uma visão coesa do processo. Onde obter Campo SWIFT 20 (TRN) ou Campo 121 (UETR) em cabeçalhos de mensagem. Exemplos TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	Nome da Atividade ActivityName	O nome da etapa do processo ou evento que ocorreu.
Descrição Este atributo descreve a ação específica ou mudança de status registrada no log do sistema. Exemplos: 'Solicitação de Pagamento Criada', 'Aprovado no Screening de Sanções' ou 'ACK SWIFT Recebido'. É a dimensão principal para os mapas de processos, definindo os nós na visualização e permitindo entender a sequência de operações realizadas em um pagamento. Por que é importante Define o "quê" do processo, permitindo a visualização do fluxo e das variações. Onde obter Logs de transação, trilhas de auditoria ou derivados de Tipos de Mensagem (ex: MT103 Sent). Exemplos Solicitação de Pagamento CriadaInstrução de Pagamento EnviadaACK SWIFT RecebidoPagamento Aprovado
	Sistema de Origem SourceSystem	O nome do sistema de onde os dados do evento se originaram.
Descrição Identifica o software ou plataforma que gerou o event log. Em um processo de pagamento, pode ser o sistema core banking, o gateway de pagamento ou a interface SWIFT direta. Este atributo ajuda na verificação da linhagem dos dados e na depuração de problemas ao mesclar dados de múltiplas aplicações bancárias distintas. Por que é importante Fornece contexto para a origem dos dados, essencial para Process Mining em múltiplos sistemas. Onde obter Codificado durante o ETL ou extraído de identificadores do sistema. Exemplos SWIFT Alliance AccessCore Banking SystemMotor de PagamentoFiltro de Sanções
	Última Atualização de Dados LastDataUpdate	O registro de data e hora de quando o registro foi extraído ou atualizado pela última vez.
Descrição Indica quando os dados foram carregados pela última vez na ferramenta de Process Mining. Isso é crucial para determinar a atualidade dos dados e garantir que os dashboards reflitam o estado mais recente das operações de pagamento. Ajuda os usuários a confiarem nos dados, oferecendo transparência sobre a latência da esteira de relatórios. Por que é importante Garante que os usuários compreendam a atualidade e a confiabilidade dos dados apresentados. Onde obter Timestamp de execução do processo ETL. Exemplos 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	BIC do Beneficiário BeneficiaryBic	O Bank Identifier Code (BIC) da instituição recebedora.
Descrição Identifica o banco de destino do pagamento. Esta é uma dimensão crucial para o dashboard de 'Causa Raiz de Rejeição pelo Beneficiário'. Ao agrupar falhas pelo BIC do Beneficiário, o banco pode identificar contrapartes específicas que rejeitam instruções com frequência devido a problemas de qualidade de dados ou exigências de formatação específicas. Por que é importante Essencial para analisar o desempenho da contraparte e os padrões de rejeição. Onde obter Campo SWIFT 57A (Conta com Instituição) ou 58A (Instituição Beneficiária). Exemplos CITIUS33BARCGB22DRESDEFFHANDSEXX
	Código NAK SWIFT SwiftNakCode	O código de erro retornado pela rede SWIFT caso uma mensagem seja rejeitada.
Descrição Contém o código de erro específico (ex: T26, T13) fornecido em um Reconhecimento Negativo (NAK) da rede SWIFT. Este atributo alimenta o dashboard de 'Análise de Erros e Retrabalho SWIFT', permitindo a categorização de falhas técnicas para priorizar correções no sistema. Por que é importante Fornece causas raiz técnicas para rejeições no nível da rede. Onde obter Mensagens de Sistema MT 015/019, ou Campo 451 em ACK/NAK. Exemplos T26H01T13G02
	Data Valor ValueDate	A data em que os fundos devem ser disponibilizados ao beneficiário.
Descrição Representa a data de liquidação instruída na mensagem de pagamento. Comparar essa data com o timestamp real de 'Pagamento Liquidado' ajuda no Dashboard de 'Aging de Liquidação e Conciliação'. Indica a urgência do pagamento e é usado para medir o cumprimento de SLAs em relação à disponibilidade de fundos. Por que é importante Crítico para a gestão de liquidez e para medir a pontualidade da liquidação. Onde obter Campo SWIFT MT 32A (subcampo Date) ou ISO 20022 IntrBkSttlmDt. Exemplos 2023-10-262023-11-01
	É STP IsStp	Sinalizador que indica se o pagamento não exigiu intervenção manual.
Descrição Um indicador booleano que é Verdadeiro se o caso não contiver atividades de 'Erro Identificado', 'Pagamento Rejeitado' ou 'Modificação' manual. Isso calcula diretamente o KPI de 'Taxa de Processamento Direto (STP)'. É a principal métrica para o sucesso da automação no processamento de pagamentos. Por que é importante A principal métrica de eficiência do processo e saúde da automação. Onde obter Calculado com base na ausência de atividades negativas/manuais específicas no caso. Exemplos verdadeirofalse
	Moeda da Transação TransactionCurrency	O código ISO de 3 letras que indica a moeda do pagamento.
Descrição Identifica a moeda na qual o pagamento é denominado (ex: USD, EUR, GBP). Isso é crítico para o dashboard de 'Performance de Horário de Corte da Rede', já que os horários limites variam por moeda. Também apoia a análise de 'Eficiência de Conversão de Moeda' ao identificar pares entre moedas distintas. Por que é importante Determina regras de roteamento, horários de corte e corredores de liquidação. Onde obter Campo SWIFT MT 32A (Currency) ou elemento ISO 20022 Ccy. Exemplos USDEURGBPJPY
	Tipo de Mensagem SWIFT SwiftMessageType	O tipo de mensagem SWIFT utilizada (ex: MT103, pacs.008).
Descrição Indica o formato específico da instrução de pagamento. Tipos comuns incluem MT103 para transferências de clientes e equivalentes ISO 20022, como o pacs.008. Usado na 'Análise de Variantes da Jornada de Pagamento' para comparar a eficiência de processamento dos formatos MT legados em relação aos novos padrões ISO. Por que é importante Diferencia os fluxos de pagamento e os padrões de processamento (Legado vs. ISO 20022). Onde obter Bloco SWIFT 2 (Cabeçalho de Aplicação), campo Message Type. Exemplos MT103MT202pacs.008MT101
	UETR UniqueEndToEndReference	A Referência Única de Transação de Ponta a Ponta para rastreamento no SWIFT gpi.
Descrição O UETR é uma string de 36 caracteres que fornece uma referência única e imutável para um pagamento em toda a rede SWIFT. Diferente de IDs internos, o UETR persiste entre os bancos. Este atributo é vital para a visibilidade de ponta a ponta e para correlacionar logs internos com atualizações externas de status SWIFT gpi. Por que é importante O padrão ouro para rastrear pagamentos internacionais entre diferentes instituições. Onde obter Bloco SWIFT 3, Campo 121. Exemplos b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Usuário de Processamento ProcessingUser	O usuário ou agente do sistema que realizou a atividade.
Descrição Identifica o indivíduo ou robô automatizado responsável pela atividade, como um oficial de conformidade aprovando uma ocorrência de sanção ou um operador corrigindo um erro de formatação. Este atributo alimenta o 'Mapa de Calor de Erros de Validação', permitindo que gestores identifiquem necessidades de treinamento ou usuários específicos associados a altas taxas de retrabalho. Por que é importante Permite análise de recursos e identificação de gargalos manuais. Onde obter Logs de auditoria do sistema, coluna 'User ID' em tabelas de transação. Exemplos SISTEMAJ.DoeCompliance_Bot_01M.Smith
	Valor da Transação TransactionAmount	O valor monetário da instrução de pagamento.
Descrição Representa o valor principal sendo transferido. Esses dados são extraídos de campos SWIFT específicos (ex: Campo 32A no MT103). É essencial para o Dashboard de 'Ciclos de Aprovação de Transferências de Alto Valor', permitindo segmentar pagamentos por tamanho para analisar atrasos de aprovação em transações de alto risco e valor. Por que é importante Permite análise de impacto financeiro e segmentação por tamanho de transação. Onde obter Campo SWIFT MT 32A (Amount) ou elemento ISO 20022 IntrBkSttlmAmt. Exemplos 15000.001250.501000000.0045.00
	Dentro do Horário Limite MetCutOffTime	Sinalizador que indica se a instrução foi enviada antes do prazo da rede.
Descrição Um sinalizador booleano calculado comparando o horário de 'Instrução de Pagamento Enviada' com o horário de corte (cut-off) da rede SWIFT específico para cada moeda. Isso apoia o KPI de 'Taxa de Aderência ao Cut-off da SWIFT'. O não cumprimento dos horários de corte resulta em atrasos na liquidação, impactando as posições de liquidez. Por que é importante KPI operacional crucial para a tesouraria e gestão de liquidez. Onde obter Calculado comparando o timestamp com uma tabela de referência estática de horários de corte. Exemplos verdadeirofalse
	Duração do Screening de Sanções SanctionsScreeningDuration	Tempo gasto na fase de screening de sanções.
Descrição Calcula a duração entre 'Detalhes do Pagamento Validados' e 'Pagamento Aprovado'. Isso alimenta diretamente o dashboard de 'Tempo de Ciclo de Triagem de Sanções'. Ele destaca transações específicas que ficam presas em filas de conformidade, impactando o rendimento geral. Por que é importante Medida direta da eficiência de conformidade e do impacto nos SLAs dos clientes. Onde obter Diferença calculada entre os timestamps de atividades específicas. Exemplos 1200005003600000
	É Internacional IsCrossBorder	Sinalizador que indica se o pagamento envolve países diferentes.
Descrição Um atributo booleano que é Verdadeiro se o País do Remetente for diferente do País do Beneficiário. Isso apoia o KPI de 'Latência no Manuseio de Múltiplas Moedas' ao separar os fluxos domésticos dos internacionais. Pagamentos transfronteiriços geralmente apresentam maior complexidade, custos e tempos de processamento. Por que é importante Segmentação fundamental para análise de complexidade de pagamentos. Onde obter Comparação do código de país do BIC Remetente vs BIC Beneficiário. Exemplos verdadeirofalse
	Motivo da Rejeição RejectionReason	Descrição textual explicando por que um pagamento foi rejeitado.
Descrição Contém a narrativa ou descrição do código quando um pagamento falha, geralmente encontrada no Campo 72 da SWIFT (Informações do Remetente para o Destinatário) ou em mensagens de retorno. Isso apoia a análise da 'Causa Raiz de Rejeição pelo Beneficiário'. Isso permite que os analistas realizem mineração de texto para encontrar temas comuns nas rejeições (ex: 'Conta Inválida', 'Divergência de Nome do Beneficiário'). Por que é importante Fornece contexto qualitativo para falhas no processo. Onde obter Campo SWIFT 72 ou 79 em mensagens de retorno (MT103 Return). Exemplos Conta do Beneficiário EncerradaIBAN InválidoFalha de Conformidade RegulatóriaIdentificador Bancário Desconhecido
	País de Origem OriginatingCountry	O código do país da entidade que inicia o pagamento.
Descrição Indica a jurisdição onde a solicitação de pagamento se originou. Isso é vital para o dashboard de 'Tempo de Ciclo de Triagem de Sanções', pois pagamentos de jurisdições de alto risco geralmente passam por verificações de conformidade mais rigorosas e longas. Permite a análise geográfica de volumes de pagamento e atrasos no processamento. Por que é importante Dimensão fundamental para análise de risco de conformidade e desempenho regional. Onde obter Derivado do BIC do Remetente (caracteres 5-6 do Código do País). Exemplos EUAGBDEFR
	Prioridade da Instrução InstructionPriority	A flag de prioridade indicando a urgência do pagamento.
Descrição Derivado dos cabeçalhos das mensagens (ex: 'Normal' vs 'Urgente'). Isso permite a segmentação no dashboard de 'Ciclos de Aprovação de Transferências de Alto Valor', já que pagamentos urgentes geralmente exigem fluxos de aprovação acelerados. Entender a distribuição de prioridades ajuda no planejamento de recursos para períodos de pico. Por que é importante Ajuda a distinguir os requisitos de SLA entre pagamentos padrão e urgentes. Onde obter Bloco SWIFT 2, campo Message Priority (ex: N para Normal, U para Urgente). Exemplos NormalUrgenteSistema

Obrigatório Recomendado Opcional

Atividades de Processamento de Pagamentos

Estas são as principais etapas do processo e marcos a serem capturados no seu log de eventos para uma descoberta precisa de processos e identificação de gargalos.

6 Recomendado 6 Opcional

	Atividade	Descrição
	Aprovado no Screening de Sanções	O timestamp de quando a instrução de pagamento passa com sucesso pelo screening de listas da OFAC/Sanções. Capturado de logs do sistema de conformidade ou inferido quando um status de 'Retenção por Screening' é liberado.
Por que é importante Crítico para o dashboard de 'Tempo de Ciclo de Triagem de Sanções'. Atrasos aqui representam gargalos de conformidade, em vez de ineficiências operacionais. Onde obter Logs do Sistema de Filtragem de Conformidade ou sinalizadores de status de conformidade do Payment Hub. Captura Registrado quando o status da triagem é atualizado Tipo de evento explicit
	Instrução de Pagamento Enviada	A transmissão da mensagem formatada (MT103 ou ISO 20022 pacs.008) para o Gateway SWIFT. Capturado quando o payload da mensagem é gerado e entregue à interface de rede.
Por que é importante Usado para calcular a 'Taxa de Aderência ao Cut-off SWIFT'. Marca a transição do processamento interno para o processamento de rede. Onde obter Logs do SWIFT Alliance Access (SAA) ou logs de transmissão de Gateway. Captura Registrado quando ocorre a saída da mensagem Tipo de evento explicit
	Pagamento Aprovado	A ação final de autorização por um aprovador designado ou regra automatizada para transferências de alto valor. Capturado quando a flag do workflow de aprovação é definida como verdadeira.
Por que é importante Chave para o dashboard de 'Ciclos de Aprovação de Transferências de Alto Valor'. Identifica atrasos em aprovações manuais para grandes movimentações de liquidez. Onde obter Trilha de auditoria do motor do workflow de aprovação. Captura Registrado quando a ação de aprovação é executada Tipo de evento explicit
	Pagamento Conciliado	O cruzamento da transação de pagamento com o extrato da conta Nostro/Vostro. Inferido quando o sistema de conciliação vincula o ID da transação a um item de linha do extrato.
Por que é importante Fecha o ciclo financeiro. Atrasos aqui impactam a visibilidade do caixa e a auditabilidade. Onde obter Logs do Sistema de Conciliação ou status 'Conciliado' no Core Banking. Captura Comparar status de reconciliação Tipo de evento inferred
	Pagamento Liquidado	A confirmação de que os fundos foram creditados na conta do beneficiário (geralmente status gpi ACSC). Capturado explicitamente via atualizações de tracker ou mensagens de confirmação.
Por que é importante Representa o fim funcional bem-sucedido da cadeia de pagamento. Crucial para calcular o 'Gap entre Liquidação e Conciliação'. Onde obter Tracker SWIFT gpi (status ACSC) ou confirmações MT900/910. Captura Registrado quando a liquidação é confirmada Tipo de evento explicit
	Solicitação de Pagamento Criada	A geração inicial da instrução de pagamento dentro do sistema bancário interno ou ERP. Capturado explicitamente quando uma referência única de transação (TRN ou UETR) é atribuída pela primeira vez à ordem de pagamento.
Por que é importante Estabelece 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 em etapas anteriores ao envio para a rede SWIFT. Onde obter Timestamp de criação da tabela de transação no Core Banking (CBS) ou Hub de Pagamentos. Captura Registrado quando o registro da transação é criado Tipo de evento explicit
	ACK SWIFT Recebido	O recebimento de uma Confirmação Técnica (ACK) da rede SWIFT, confirmando que a mensagem foi aceita para processamento. Capturado dos logs da interface de rede.
Por que é importante Confirma que a mensagem entrou com sucesso na rede global. Diferencia falhas internas de propagação real na rede. Onde obter Logs do Gateway SWIFT (buscando sinais ACK vs NACK). Captura Registrado quando o ACK da rede é recebido Tipo de evento explicit
	Detalhes do Pagamento Validados	A conclusão bem-sucedida das verificações de sintaxe e formato (ex: formato IBAN, validade BIC) na instrução de pagamento. Inferido quando o status da transação muda de 'Rascunho' para 'Validado' ou 'Pronto para Autorização'.
Por que é importante Altas taxas de falha aqui indicam baixa qualidade de dados na fonte. Mede o KPI de 'Rendimento de Validação de Primeira Passagem'. Onde obter Logs de status do Motor de Pagamento ou tabelas de histórico de validação. Captura Comparar campo de status antes/depois Tipo de evento inferred
	Erro de Pagamento Identificado	O evento em que uma transação é sinalizada para reparo devido a falhas de validação, NACKs ou mensagens de rejeição. Inferido quando a transação entra em uma fila de 'Reparo', 'Correção' ou 'Exceção'.
Por que é importante Rastreia a 'Taxa de Retrabalho na Resolução de Erros'. A alta frequência aqui prejudica as taxas de Straight-Through Processing (STP). Onde obter Colunas de status do Hub de Pagamentos ou logs de fila de exceção. Captura Comparar campo de status com Erro/Reparo Tipo de evento inferred
	Erro de Pagamento Resolvido	A modificação e o reenvio bem-sucedidos de uma transação que estava em erro anteriormente. Inferido quando a transação sai da fila de 'Reparo' e volta para o estado de 'Processamento' ou 'Pronto'.
Por que é importante Mede a eficiência da equipe de retrabalho manual. Durações longas aqui indicam falhas de treinamento ou códigos de erro complexos. Onde obter Logs de status do Hub de Pagamentos mostrando a saída das filas de exceção. Captura Comparar campo de status saída de Reparo Tipo de evento inferred
	Pagamento Rejeitado	O recebimento de uma mensagem de rejeição (MT103 Return ou status gpi RJCT) de um beneficiário ou banco intermediário. Capturado de mensagens SWIFT recebidas.
Por que é importante Crítico para o dashboard de 'Causa Raiz de Rejeição pelo Beneficiário'. Identifica bloqueios externos como contas encerradas ou dados de roteamento incorretos. Onde obter Mensagens SWIFT de entrada (MT103 RET, pacs.004) ou status gpi RJCT. Captura Registrado quando a mensagem de rejeição é recebida Tipo de evento explicit
	Pagamento Transferido	Uma atualização de status intermediária (geralmente status gpi ACSP) indicando que o pagamento está sendo processado por um banco intermediário. Capturado via atualizações do SWIFT gpi Tracker ou mensagens de status.
Por que é importante Oferece visibilidade sobre a 'caixa preta' do banco correspondente. Essencial para analisar a jornada total de ponta a ponta. Onde obter Feeds de dados SWIFT gpi Tracker ou mensagens MT199/trck. Captura 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

Faça login na SWIFT Alliance WebPlatform ou na GUI do Alliance Access usando uma conta de administrador com acesso à configuração de arquivamento (Archiving).
Navegue até o menu de Gerenciamento do Sistema (System Management), selecione Arquivamento (Archiving) e escolha Configuração de Arquivamento Automatizado (Automated Archiving Configuration).
Configure um novo perfil de Exportação Diária. Defina o Diretório de Destino para um caminho de rede seguro acessível pelos seus scripts de extração.
Especifique o Escopo do Conteúdo: Selecione 'Mensagens' e garanta que as opções 'Incluir Histórico' e 'Incluir Intervenções' estejam marcadas. Isso é crítico para capturar eventos de trilha de auditoria, como aprovações e validações.
Selecione o Formato de Saída. Escolha XML (especificamente o schema 'SAA XML v2' ou o mais recente disponível), pois ele preserva a relação hierárquica entre o cabeçalho da mensagem e os eventos de histórico melhor do que o CSV.
Defina os filtros de Intervalo de Datas para extrair o período histórico necessário para a iniciativa de Process Mining, ou configure para execução diária para dados D-1.
Execute o trabalho de Exportação de Arquivo manualmente para a carga inicial, ou aguarde a conclusão do job agendado. 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 requer um event log em CSV simples, você deve executar um script de transformação. Use o script Python fornecido na seção de Consulta para processar o XML.
O script percorre cada elemento de mensagem, extraindo a Referência de Transação Única de Ponta a Ponta (UETR) ou o Número de Referência da Transação (TRN) para servir como Case ID.
Em seguida, o script itera pelos nós filhos de 'Histórico' e 'Intervenção' de cada mensagem para gerar as linhas de atividade. Ele mapeia códigos de status internos do SAA (ex: 'NetworkAck', 'Authorisation') para nomes de atividades padronizados.
Execute o script Python nos seus arquivos XML exportados para gerar o arquivo 'events.csv'.
Valide a saída do CSV para garantir que colunas como EventTimestamp estejam no formato ISO 8601 e faça o upload do arquivo para o ProcessMind.

Configuração

Formato de Arquivo: XML (Preferencial) ou CSV (Arquivo simples). O XML é altamente recomendado para capturar nós de histórico aninhados.
Incluir Texto da Mensagem: Sim (Obrigatório para o parsing de detalhes de Valor, Moeda e Beneficiário).
Incluir Histórico/Intervenções: Sim (Obrigatório para visualizar aprovações, validações e erros).
Intervalo de Datas: Configure uma janela deslizante (ex: ú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 retornos/status).
Direções: Inclua tanto Entrada (Emissão) quanto Saída (Recepção) para capturar rejeições ou confirmações recebidas.
Segurança: Certifique-se de que a pasta de exportação tenha permissões rígidas de leitura/gravação, pois esses arquivos contêm dados de pagamentos reais.

a Consulta de Exemplo config

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

# CONFIGURATION
# Update this path to your SAA XML Export directory
input_folder = "./saa_exports/"
output_file = "./swift_process_mining_log.csv"

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

data_rows = []

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

    # 7. Payment Transferred (gpi status)
    if "TrackerUpdate" in history_item_name and "ACSP" in text_content:
        return "Payment Transferred"

    # 8. Payment Error Identified
    if nature == "NAK" or status == "Failed" or nature == "RoutingFailure":
        return "Payment Error Identified"

    # 9. Payment Error Resolved
    if history_item_name == "Modification" and nature == "Repair":
        return "Payment Error Resolved"
    
    # 10. Payment Rejected
    if "TrackerUpdate" in history_item_name and "RJCT" in text_content:
        return "Payment Rejected"

    # 11. Payment Settled
    if "TrackerUpdate" in history_item_name and "ACSC" in text_content:
        return "Payment Settled"

    # 12. Payment Reconciled
    # Often external, but if SAA receives a Reconciliation update:
    if history_item_name == "ReconciliationMatch":
        return "Payment Reconciled"
        
    return None

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

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

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

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

# OUTPUT GENERATION
df = pd.DataFrame(data_rows, columns=columns)

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

df.to_csv(output_file, index=False, quoting=1)
print(f"Extraction Complete. Processed {len(df)} events into {output_file}")

Etapas

Prepare o Ambiente: Verifique se o Python 3.8+ está instalado no servidor de extração. Instale as bibliotecas necessárias via pip (pandas, numpy). Crie um diretório de trabalho dedicado com uma subpasta chamada raw_swift_files e coloque todos os arquivos diários .out, .txt ou .fin nela.
Entenda a Estrutura do Arquivo: As mensagens brutas SWIFT FIN são estruturadas em blocos ({1: Header} {2: Application} {4: Body}). Identifique os delimitadores. Arquivos padrão usam chaves. Certifique-se de que seus arquivos não estejam envoltos em formatos proprietários (como cabeçalhos RJE) ou remova-os antes do processamento.
Configure os Caminhos do Script: Abra o script Python fornecido. Atualize a variável INPUT_DIRECTORY para apontar para sua pasta raw_swift_files. Atualize o caminho do OUTPUT_FILE para o CSV resultante.
Defina 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 (ex: I103, O103) e o BIC do Destinatário. O Bloco 4 contém as tags de dados de negócio (ex: :20: TRN, :32A: Valor/Moeda).
Mapeie Tipos de Mensagem para Atividades: O script contém um dicionário de mapeamento. MT103 implica em 'Instrução de Pagamento Enviada'. MT012 (ACK de Sistema) implica em 'ACK SWIFT Recebido'. MT900/910 implica em 'Pagamento Liquidado'. MT199/299 com códigos de status específicos (ACSP, RJCT) mapeiam para 'Pagamento Transferido' ou 'Pagamento Rejeitado'.
Extraia Atributos: O parser itera por tags específicas. :20: é mapeado para ID da Transação de Pagamento. :121: é mapeado para UETR. :32A: é processado em Data, Moeda e Valor.
Lide com Estados Internos: Para atividades como 'Solicitação de Pagamento Criada' ou 'Pagamento Aprovado', que costumam ser eventos internos de ERP fora dos arquivos SWIFT, o script deriva estes dados do Timestamp de Criação da Mensagem no Bloco 1 (caso não haja logs explícitos) ou busca códigos de texto específicos no campo :72: (Info Remetente para Destinatário) se sua empresa registrar aprovações lá.
Execute a Extração: Execute o script via linha de comando: python swift_parser.py. O script percorrerá todos os arquivos, processando blocos SWIFT válidos e pulando linhas malformadas.
Validação Pós-Processamento: Abra o CSV gerado. Verifique o formato do EventTimestamp (recomenda-se ISO 8601). Certifique-se de que o PaymentTransactionId esteja preenchido em todas as linhas para permitir o agrupamento de casos.
Transformação de Dados: Se o 'ValueDate' aparecer como YYMMDD, o script o converterá para YYYY-MM-DD. Garanta que os separadores decimais em 'TransactionAmount' estejam padronizados (pontos vs vírgulas).
Revisão Final: Filtre por um UETR específico para ver o fluxo de ponta a ponta: Instrução Enviada -> ACK -> Liquidação. Verifique se os NAKs (MT019) aparecem como 'Erro de Pagamento Identificado'.
Upload para o ProcessMind: Importe o CSV. Mapeie PaymentTransactionId para Case ID, ActivityName para Atividade e EventTimestamp para Timestamp.

Configuração

Diretório de Entrada (Input Directory): Caminho para a pasta que contém os arquivos simples FIN/MT brutos. Certifique-se de que as permissões de leitura foram concedidas.
Parsing de Formato de Data: As datas brutas da SWIFT seguem o formato YYMMDD. O script lida com a suposição do século (20xx).
Filtros de Tipo de Mensagem: O script foca na categoria 1 (Pagamentos), 9 (Extratos) e mensagens de sistema comuns (012, 019). Ajuste a lista RELEVANT_MT_TYPES se a Categoria 2 (Transferências entre Instituições Financeiras) for necessária.
Codificação (Encoding): O padrão é 'utf-8'. Altere para 'latin-1' ou 'ascii' se os arquivos contiverem caracteres de codificação legados.
Processamento em Lote: Para conjuntos de dados maiores que 1GB, o script utiliza uma abordagem de gerador para evitar estouro de memória, processando arquivo por arquivo.
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

Prepare o Ambiente: Verifique se o Python 3.8+ está instalado no servidor de extração. Instale as bibliotecas necessárias via pip (pandas, numpy). Crie um diretório de trabalho dedicado com uma subpasta chamada raw_swift_files e coloque todos os arquivos diários .out, .txt ou .fin nela.
Entenda a Estrutura do Arquivo: As mensagens brutas SWIFT FIN são estruturadas em blocos ({1: Header} {2: Application} {4: Body}). Identifique os delimitadores. Arquivos padrão usam chaves. Certifique-se de que seus arquivos não estejam envoltos em formatos proprietários (como cabeçalhos RJE) ou remova-os antes do processamento.
Configure os Caminhos do Script: Abra o script Python fornecido. Atualize a variável INPUT_DIRECTORY para apontar para sua pasta raw_swift_files. Atualize o caminho do OUTPUT_FILE para o CSV resultante.
Defina 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 (ex: I103, O103) e o BIC do Destinatário. O Bloco 4 contém as tags de dados de negócio (ex: :20: TRN, :32A: Valor/Moeda).
Mapeie Tipos de Mensagem para Atividades: O script contém um dicionário de mapeamento. MT103 implica em 'Instrução de Pagamento Enviada'. MT012 (ACK de Sistema) implica em 'ACK SWIFT Recebido'. MT900/910 implica em 'Pagamento Liquidado'. MT199/299 com códigos de status específicos (ACSP, RJCT) mapeiam para 'Pagamento Transferido' ou 'Pagamento Rejeitado'.
Extraia Atributos: O parser itera por tags específicas. :20: é mapeado para ID da Transação de Pagamento. :121: é mapeado para UETR. :32A: é processado em Data, Moeda e Valor.
Lide com Estados Internos: Para atividades como 'Solicitação de Pagamento Criada' ou 'Pagamento Aprovado', que costumam ser eventos internos de ERP fora dos arquivos SWIFT, o script deriva estes dados do Timestamp de Criação da Mensagem no Bloco 1 (caso não haja logs explícitos) ou busca códigos de texto específicos no campo :72: (Info Remetente para Destinatário) se sua empresa registrar aprovações lá.
Execute a Extração: Execute o script via linha de comando: python swift_parser.py. O script percorrerá todos os arquivos, processando blocos SWIFT válidos e pulando linhas malformadas.
Validação Pós-Processamento: Abra o CSV gerado. Verifique o formato do EventTimestamp (recomenda-se ISO 8601). Certifique-se de que o PaymentTransactionId esteja preenchido em todas as linhas para permitir o agrupamento de casos.
Transformação de Dados: Se o 'ValueDate' aparecer como YYMMDD, o script o converterá para YYYY-MM-DD. Garanta que os separadores decimais em 'TransactionAmount' estejam padronizados (pontos vs vírgulas).
Revisão Final: Filtre por um UETR específico para ver o fluxo de ponta a ponta: Instrução Enviada -> ACK -> Liquidação. Verifique se os NAKs (MT019) aparecem como 'Erro de Pagamento Identificado'.
Upload para o ProcessMind: Importe o CSV. Mapeie PaymentTransactionId para Case ID, ActivityName para Atividade e EventTimestamp para Timestamp.

Configuração

Diretório de Entrada (Input Directory): Caminho para a pasta que contém os arquivos simples FIN/MT brutos. Certifique-se de que as permissões de leitura foram concedidas.
Parsing de Formato de Data: As datas brutas da SWIFT seguem o formato YYMMDD. O script lida com a suposição do século (20xx).
Filtros de Tipo de Mensagem: O script foca na categoria 1 (Pagamentos), 9 (Extratos) e mensagens de sistema comuns (012, 019). Ajuste a lista RELEVANT_MT_TYPES se a Categoria 2 (Transferências entre Instituições Financeiras) for necessária.
Codificação (Encoding): O padrão é 'utf-8'. Altere para 'latin-1' ou 'ascii' se os arquivos contiverem caracteres de codificação legados.
Processamento em Lote: Para conjuntos de dados maiores que 1GB, o script utiliza uma abordagem de gerador para evitar estouro de memória, processando arquivo por arquivo.
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()

Seu Template de Dados para Processamento de Pagamentos

Seu Template de Dados para Processamento de Pagamentos

Atributos de Processamento de Pagamentos

Atividades de Processamento de Pagamentos

Guias de Extração

Exportação de Arquivo SWIFT Alliance Access

Etapas

Configuração

a Consulta de Exemplo config

Parser em Python para Arquivos SWIFT MT Brutos

Etapas

Configuração

a Consulta de Exemplo python

Conector API SWIFT gpi

Etapas

Configuração

a Consulta de Exemplo python

Pronto para Começar?

Otimize seu Processamento de Pagamentos SWIFT Agora

Seu Template de Dados para Processamento de Pagamentos

Seu Template de Dados para Processamento de Pagamentos

Atributos de Processamento de Pagamentos

Atividades de Processamento de Pagamentos

Guias de Extração

Exportação de Arquivo SWIFT Alliance Access

Etapas

Configuração

a Consulta de Exemplo config

Parser em Python para Arquivos SWIFT MT Brutos

Etapas

Configuração

a Consulta de Exemplo python

Conector API SWIFT gpi

Etapas

Configuração

a Consulta de Exemplo python

Valorizamos sua privacidade

Pronto para Começar?

Otimize seu Processamento de Pagamentos SWIFT Agora