> Continu verbeteren van processen > Betalingsverwerking > SWIFT > Datatemplate

De datatemplate voor betalingsverwerking

SWIFT

Attributen voor betalingsverwerking (19) Activiteiten voor betalingsverwerking (12) Extractiegidsen (3)

De datatemplate voor betalingsverwerking

Deze template vormt de basis voor het in kaart brengen van SWIFT-transacties, van de start tot de uiteindelijke afwikkeling. Je vindt hierin de datacomponenten en procesmomenten die nodig zijn om de volledige levenscyclus van betalingen te volgen. Met deze gids bereid je de data voor en spoor je inefficiënties en compliancerisico’s op.

Aanbevolen attributen voor een grondige transactieanalyse
Belangrijke SWIFT-procesactiviteiten en -momenten
Technische richtlijnen voor data-extractie uit financiële systemen

Nieuw met event logs? Lees hoe je een event log voor process mining maakt.

Template downloaden

Attributen voor betalingsverwerking

Dit zijn de aanbevolen datavelden voor het event log, zodat je de volledige levenscyclus van SWIFT-transacties kunt analyseren.

5 Verplicht 9 Aanbevolen 5 Optioneel

	Naam	Beschrijving
	Activiteitsnaam ActivityName	De naam van de processtap of gebeurtenis.
Beschrijving Dit attribuut beschrijft de specifieke actie of statuswijziging die in het systeemlog is vastgelegd. Voorbeelden zijn ‘Betalingsaanvraag aangemaakt’, ‘Sanctiescreening geslaagd’ en ‘SWIFT-ACK ontvangen’. Dit is de belangrijkste dimensie voor proceskaarten. De activiteiten vormen de knooppunten in de visualisatie en helpen analisten de volgorde van uitgevoerde betalingsactiviteiten te begrijpen. Waarom dit belangrijk is Dit attribuut beschrijft wat er in het proces gebeurt en maakt de processtroom en variaties zichtbaar. Waar vind je dit? Transactielogs, auditsporen of gegevens afgeleid van berichttypen, zoals MT103 verzonden. Voorbeelden Betalingsaanvraag aangemaaktBetalingsopdracht verzondenSWIFT-ACK ontvangenBetaling goedgekeurd
	Bronsysteem SourceSystem	De naam van het systeem waaruit de gebeurtenisdata afkomstig is.
Beschrijving Dit attribuut geeft aan welke software of welk platform het event log heeft aangemaakt. In een betalingsproces kan dat het Core Banking System, de Payment Gateway of rechtstreeks de SWIFT-interface zijn. Het helpt de herkomst van data te controleren en problemen op te sporen wanneer data uit verschillende banksystemen wordt samengevoegd. Waarom dit belangrijk is Geeft context over de herkomst van data, wat belangrijk is voor process mining in meerdere systemen. Waar vind je dit? Vast ingesteld tijdens ETL of opgehaald uit systeemidentificaties. Voorbeelden SWIFT Alliance AccessCore Banking SystemPayment EngineSanctiefilter
	Laatste data-update LastDataUpdate	De timestamp waarop het record voor het laatst is geëxtraheerd of bijgewerkt.
Beschrijving Geeft aan wanneer de data voor het laatst in de process mining-tool is geladen. Zo kun je bepalen hoe actueel de data is en controleren of de dashboards de meest recente status van de betalingsverwerking tonen. De informatie over de vertraging in de rapportageketen maakt duidelijk hoe actueel de data is en helpt gebruikers erop te vertrouwen. Waarom dit belangrijk is Helpt gebruikers de actualiteit en betrouwbaarheid van de getoonde data te beoordelen. Waar vind je dit? Timestamp van de ETL-procesuitvoering. Voorbeelden 2023-10-27T12:00:00Z2023-11-01T06:00:00Z
	Timestamp van gebeurtenis EventTimestamp	De exacte datum en tijd waarop de activiteit plaatsvond.
Beschrijving Dit attribuut registreert het exacte moment waarop een gebeurtenis plaatsvond. Het wordt gebruikt om activiteiten chronologisch te ordenen en alle tijdsgebonden metrieken te berekenen, zoals doorlooptijden en doorvoer. Nauwkeurige timestamps zijn belangrijk om de prestaties rond netwerkdeadlines te analyseren en bottlenecks in de goedkeuringsketen te herkennen. Waarom dit belangrijk is Timestamps vormen de basis voor alle tijdsanalyses en prestatiemetrieken in process mining. Waar vind je dit? Systeemlogs voor audits, timestamps van berichtaanmaak of transactietijden uit databases. Voorbeelden 2023-10-25T08:30:15Z2023-10-25T14:45:00Z2023-10-26T09:15:22Z
	Transactie-ID van betaling PaymentTransactionId	De unieke identificatiecode van de volledige betalingscase.
Beschrijving Dit attribuut is de centrale casecode voor process mining. Het groepeert alle activiteiten van één betalingsopdracht, van de eerste aanvraag tot validatie, verzending via SWIFT en de uiteindelijke afwikkeling. In SWIFT-omgevingen wordt hiervoor vaak het Transaction Reference Number (TRN) of de Unique End-to-end Transaction Reference (UETR) gebruikt, zodat de betaling in verschillende banksystemen te volgen is. De code wordt gebruikt om het procesverloop van een case te reconstrueren en is nodig voor variantanalyses en berekeningen van doorlooptijden. Waarom dit belangrijk is Unieke identificatie is de basis van process mining. Hiermee kun je losse gebeurtenissen samenvoegen tot één samenhangend beeld van het proces. Waar vind je dit? SWIFT-veld 20 (TRN) of veld 121 (UETR) in berichtkoppen. Voorbeelden TRN-20231025-883954392-882-101UETR-9982-1123-5521PAY-US-EU-9912
	BIC van de begunstigde BeneficiaryBic	De Bank Identifier Code van de ontvangende instelling.
Beschrijving Geeft aan naar welke bank de betaling gaat. Dit is een belangrijke dimensie voor het dashboard 'Oorzaakanalyse van afwijzingen door begunstigden'. Door afwijzingen te groeperen op BIC van de begunstigde, kan de bank zien welke tegenpartijen opdrachten vaak afwijzen vanwege problemen met de datakwaliteit of specifieke opmaakvereisten. Waarom dit belangrijk is Essentieel voor het analyseren van prestaties van tegenpartijen en afwijzingspatronen. Waar vind je dit? SWIFT-veld 57A (Account With Institution) of 58A (Beneficiary Institution). Voorbeelden CITIUS33BARCGB22DRESDEFFHANDSEXX
	STP IsStp	Markering die aangeeft of de betaling zonder handmatige tussenkomst is verwerkt.
Beschrijving Een booleaanse indicator die True is als de case geen activiteiten bevat zoals 'Fout vastgesteld', 'Betaling afgewezen' of handmatige 'Wijziging'. Hiermee wordt de KPI 'Percentage Straight-Through Processing' berekend. Dit is de belangrijkste metriek voor het meten van automatisering bij betalingsverwerking. Waarom dit belangrijk is De belangrijkste maatstaf voor procesefficiëntie en de werking van automatisering. Waar vind je dit? Berekend op basis van het ontbreken van specifieke negatieve of handmatige activiteiten in de case. Voorbeelden truefalse
	SWIFT NAK-code SwiftNakCode	De foutcode die het SWIFT-netwerk terugstuurt als een bericht wordt afgewezen.
Beschrijving Bevat de specifieke foutcode (bijvoorbeeld T26 of T13) uit een Negative Acknowledgment (NAK) van het SWIFT-netwerk. Dit attribuut vormt de basis voor het dashboard 'Analyse van SWIFT-fouten en herhaalwerk'. Zo kun je technische fouten categoriseren en bepalen welke systeemproblemen je als eerste aanpakt. Waarom dit belangrijk is Geeft de technische oorzaken van afwijzingen op netwerkniveau. Waar vind je dit? Systeemberichten MT 015/019 of veld 451 in ACK/NAK. Voorbeelden T26H01T13G02
	SWIFT-berichttype SwiftMessageType	Het type SWIFT-bericht dat is gebruikt (bijvoorbeeld MT103 of pacs.008).
Beschrijving Geeft het specifieke formaat van de betalingsopdracht aan. Veelgebruikte typen zijn MT103 voor klantbetalingen en de ISO 20022-equivalenten, zoals pacs.008. Wordt gebruikt in 'Analyse van betalingsvarianten' om de verwerkingsefficiëntie van oudere MT-formaten te vergelijken met die van de nieuwe ISO-standaarden. Waarom dit belangrijk is Maakt onderscheid tussen betalingsstromen en verwerkingsstandaarden (verouderd versus ISO 20022). Waar vind je dit? SWIFT-blok 2 (applicatieheader), veld Berichttype. Voorbeelden MT103MT202pacs.008MT101
	Transactiebedrag TransactionAmount	Het geldbedrag van de betalingsopdracht.
Beschrijving Dit is het bedrag dat wordt overgemaakt. De data wordt opgehaald uit specifieke SWIFT-velden, zoals veld 32A in MT103. Dit is belangrijk voor het dashboard ‘Goedkeuringscycli voor grote overboekingen’. Je kunt betalingen op bedrag indelen en vertragingen bij de goedkeuring van risicovolle, grote transacties analyseren. Waarom dit belangrijk is Maakt analyses van de financiële impact en indeling op basis van transactiebedrag mogelijk. Waar vind je dit? SWIFT MT-veld 32A (bedrag) of ISO 20022-element IntrBkSttlmAmt. Voorbeelden 15000.001250.501000000.0045.00
	Transactievaluta TransactionCurrency	De ISO-code van 3 letters die de valuta van de betaling aangeeft.
Beschrijving Geeft aan in welke valuta de betaling is uitgedrukt (bijvoorbeeld USD, EUR of GBP). Dit is belangrijk voor het dashboard 'Prestaties van netwerkdeadlines', omdat de deadlines per valuta verschillen. Ook voor de analyse 'Efficiëntie van valutaconversie' is dit gegeven nodig om valutaparen te herkennen. Waarom dit belangrijk is Bepaalt de routeringsregels, deadlines en afwikkelingscorridors. Waar vind je dit? SWIFT MT-veld 32A (valuta) of ISO 20022-element Ccy. Voorbeelden USDEURGBPJPY
	UETR UniqueEndToEndReference	De Unique End-to-end Transaction Reference voor het volgen van betalingen via SWIFT gpi.
Beschrijving De UETR is een tekenreeks van 36 tekens die een unieke, onveranderlijke referentie biedt voor een betaling binnen het hele SWIFT-netwerk. In tegenstelling tot interne ID’s blijft de UETR bij de betaling, ook als die tussen banken wordt doorgegeven. Dit attribuut is essentieel voor inzicht in het volledige betalingstraject en om interne logs te koppelen aan externe statusupdates van SWIFT gpi. Waarom dit belangrijk is De standaard voor het volgen van grensoverschrijdende betalingen tussen verschillende instellingen. Waar vind je dit? SWIFT-blok 3, veld 121. Voorbeelden b8c3f4a0-5d2a-4e1b-9c3d-1a2b3c4d5e6f123e4567-e89b-12d3-a456-426614174000
	Valutadatum ValueDate	De datum waarop het geld beschikbaar moet zijn voor de begunstigde.
Beschrijving De afwikkelingsdatum die in het betalingsbericht is opgegeven. Door deze te vergelijken met de timestamp van 'Betaling afgewikkeld' krijg je inzicht in het dashboard 'Achterstanden in afwikkeling en reconciliatie'. De datum geeft aan hoe urgent de betaling is en helpt meten of afspraken over de beschikbaarheid van geld worden nagekomen. Waarom dit belangrijk is Belangrijk voor liquiditeitsbeheer en het meten van tijdige afwikkeling. Waar vind je dit? SWIFT MT-veld 32A (datumsubveld) of ISO 20022 IntrBkSttlmDt. Voorbeelden 2023-10-262023-11-01
	Verwerkende gebruiker ProcessingUser	De gebruiker of systeemagent die de activiteit heeft uitgevoerd.
Beschrijving Geeft aan welke persoon of geautomatiseerde bot verantwoordelijk was voor de activiteit, bijvoorbeeld een compliance-medewerker die een sanctiemelding goedkeurt of een operator die een opmaakfout herstelt. Dit attribuut vormt de basis voor de 'Heatmap van validatiefouten'. Managers zien zo waar training nodig is en welke gebruikers vaak met herhaalwerk te maken hebben. Waarom dit belangrijk is Maakt bronanalyse mogelijk en helpt handmatige bottlenecks te vinden. Waar vind je dit? Systeemlogs voor audits, kolom 'User ID' in transactietabellen. Voorbeelden SYSTEEMJ.DoeCompliance_Bot_01M.Smith
	Deadline gehaald MetCutOffTime	Markering die aangeeft of de opdracht vóór de deadline van het netwerk is verzonden.
Beschrijving Een booleaanse markering die wordt berekend door het tijdstip van 'Betalingsopdracht verzonden' te vergelijken met de SWIFT-deadline voor de betreffende valuta. Dit ondersteunt de KPI 'Percentage SWIFT-deadlines gehaald'. Als een deadline niet wordt gehaald, loopt de afwikkeling vertraging op en kan de liquiditeitspositie veranderen. Waarom dit belangrijk is Belangrijke operationele KPI voor treasury- en liquiditeitsbeheer. Waar vind je dit? Berekend door de timestamp te vergelijken met een statische referentietabel met deadlines. Voorbeelden truefalse
	Grensoverschrijdend IsCrossBorder	Markering die aangeeft of de betaling betrekking heeft op verschillende landen.
Beschrijving Een booleaans attribuut dat True is als het land van de verzender verschilt van dat van de begunstigde. Hiermee kun je binnen de KPI 'Vertraging bij verwerking van meerdere valuta' binnenlandse en internationale betalingsstromen apart bekijken. Grensoverschrijdende betalingen zijn doorgaans complexer, duurder en nemen meer tijd in beslag. Waarom dit belangrijk is Essentiële segmentatie voor de analyse van de complexiteit van betalingen. Waar vind je dit? Vergelijking van de landcode in de BIC van de verzender met die in de BIC van de begunstigde. Voorbeelden truefalse
	Land van herkomst OriginatingCountry	De landcode van de entiteit die de betaling initieert.
Beschrijving Geeft aan vanuit welk rechtsgebied het betalingsverzoek is gestart. Dit is belangrijk voor het dashboard 'Doorlooptijd van sanctiescreening', omdat betalingen uit rechtsgebieden met een hoog risico vaak grondiger en langer op compliance worden gecontroleerd. Hiermee kun je betalingsvolumes en verwerkingsvertragingen geografisch analyseren. Waarom dit belangrijk is Belangrijke dimensie voor analyse van compliancerisico’s en regionale prestaties. Waar vind je dit? Afgeleid van de BIC van de verzender (tekens 5 en 6 vormen de landcode). Voorbeelden USGBDEFR
	Prioriteit van de opdracht InstructionPriority	De prioriteitsmarkering die aangeeft hoe urgent de betaling is.
Beschrijving Afgeleid uit de berichtheaders (bijvoorbeeld 'Normaal' of 'Urgent'). Hiermee kun je segmenteren in het dashboard 'Goedkeuringscycli voor grote betalingen', omdat urgente betalingen vaak sneller moeten worden goedgekeurd. Inzicht in de verdeling van prioriteiten helpt bij het plannen van capaciteit tijdens piekuren. Waarom dit belangrijk is Helpt de SLA-vereisten voor standaardbetalingen te onderscheiden van die voor versnelde betalingen. Waar vind je dit? SWIFT-blok 2, veld Berichtprioriteit (bijvoorbeeld N voor normaal, U voor urgent). Voorbeelden NormaalUrgentSysteem
	Reden van afwijzing RejectionReason	Tekst die uitlegt waarom een betaling is afgewezen.
Beschrijving Bevat de toelichting of codebeschrijving bij een mislukte betaling. Deze staat meestal in SWIFT-veld 72 (Sender to Receiver Information) of in retourberichten. Dit ondersteunt de analyse 'Oorzaakanalyse van afwijzingen door begunstigden'. Analisten kunnen de tekst doorzoeken om veelvoorkomende afwijzingsredenen te vinden, zoals 'Ongeldig rekeningnummer' of 'Naam begunstigde komt niet overeen'. Waarom dit belangrijk is Geeft context bij procesfouten. Waar vind je dit? SWIFT-veld 72 of 79 in retourberichten (MT103 Return). Voorbeelden Rekening van begunstigde geslotenOngeldig IBANNiet voldaan aan wettelijke compliance-eisenBank niet bekend

Verplicht Aanbevolen Optioneel

Activiteiten voor betalingsverwerking

Dit zijn de belangrijkste processtappen en momenten om in het event log vast te leggen. Zo kun je het proces goed ontdekken en bottlenecks opsporen.

6 Aanbevolen 6 Optioneel

	Activiteit	Beschrijving
	Betaling afgestemd	De betalingstransactie wordt vergeleken met het rekeningafschrift van de Nostro- of Vostro-rekening. Dit is af te leiden wanneer het afstemmingssysteem de transactie-ID koppelt aan een regel op het afschrift.
Waarom dit belangrijk is Hiermee is de financiële verwerking afgerond. Vertragingen hebben gevolgen voor het inzicht in de kaspositie en de controleerbaarheid. Waar vind je dit? Logs van het afstemmingssysteem of de status ‘Gematcht’ in het Core Banking System. Vastleggen Controleer de afstemmingsstatus Gebeurtenistype inferred
	Betaling afgewikkeld	Bevestiging dat het bedrag op de rekening van de begunstigde is bijgeschreven, vaak met de gpi-status ACSC. Dit wordt rechtstreeks vastgelegd via trackerupdates of bevestigingsberichten.
Waarom dit belangrijk is Dit is het functionele eindpunt van de betalingsketen. Belangrijk voor het berekenen van de tijd tussen afwikkeling en afstemming. Waar vind je dit? SWIFT gpi Tracker (status ACSC) of MT900/910-bevestigingen. Vastleggen Vastgelegd wanneer de afwikkeling is bevestigd Gebeurtenistype explicit
	Betaling goedgekeurd	De definitieve autorisatie door een bevoegde medewerker of een geautomatiseerde regel voor grote overboekingen. Dit wordt rechtstreeks vastgelegd wanneer de goedkeuringsworkflow op waar wordt gezet.
Waarom dit belangrijk is Belangrijk voor het dashboard ‘Goedkeuringscycli voor grote overboekingen’. Hiermee herken je vertragingen bij handmatige goedkeuringen van grote geldstromen. Waar vind je dit? Auditspoor van de goedkeuringsworkflow-engine. Vastleggen Vastgelegd wanneer de goedkeuringsactie is uitgevoerd Gebeurtenistype explicit
	Betalingsaanvraag aangemaakt	De betalingsopdracht wordt aangemaakt in het interne banksysteem of ERP. Dit moment wordt expliciet vastgelegd wanneer voor het eerst een unieke transactiecode (TRN of UETR) aan de betalingsopdracht wordt toegekend.
Waarom dit belangrijk is Hiermee wordt de starttijd van de volledige betalingslevenscyclus bepaald. Dit is nodig om de totale verwerkingstijd te berekenen en vertragingen vóór verzending via het SWIFT-netwerk te herkennen. Waar vind je dit? Timestamp waarop de transactietabel is aangemaakt in het Core Banking System (CBS) of de Payment Hub. Vastleggen Vastgelegd bij het aanmaken van het transactierecord Gebeurtenistype explicit
	Betalingsopdracht verzonden	Het opgemaakte bericht (MT103 of ISO 20022 pacs.008) wordt naar de SWIFT Gateway verzonden. Dit wordt rechtstreeks vastgelegd wanneer de berichtinhoud is aangemaakt en aan de netwerkinterface is overgedragen.
Waarom dit belangrijk is Wordt gebruikt om het percentage betalingen te berekenen dat de SWIFT-deadline haalt. Dit markeert de overgang van interne verwerking naar netwerkverwerking. Waar vind je dit? Logs van SWIFT Alliance Access (SAA) of verzendlogs van de Gateway. Vastleggen Vastgelegd wanneer het bericht is verzonden Gebeurtenistype explicit
	Sanctiescreening geslaagd	De timestamp waarop de betalingsopdracht de screening aan de hand van de OFAC- of sanctielijst met succes doorstaat. Dit wordt rechtstreeks vastgelegd in logs van het compliancesysteem of afgeleid wanneer de status ‘Screening geblokkeerd’ wordt opgeheven.
Waarom dit belangrijk is Belangrijk voor het dashboard ‘Doorlooptijd sanctiescreening’. Vertragingen hier wijzen op bottlenecks bij compliance, niet op inefficiëntie in de bedrijfsvoering. Waar vind je dit? Logs van het compliancefiltersysteem of compliance-statusvelden in de Payment Hub. Vastleggen Vastgelegd wanneer de screeningsstatus wordt bijgewerkt Gebeurtenistype explicit
	Betaling afgewezen	Een afwijzingsbericht van een begunstigde of intermediaire bank wordt ontvangen, zoals een MT103 Return of de gpi-status RJCT. Dit wordt rechtstreeks vastgelegd in binnenkomende SWIFT-berichten.
Waarom dit belangrijk is Belangrijk voor het dashboard ‘Oorzaak van afwijzing door begunstigde’. Hiermee herken je externe blokkades, zoals gesloten rekeningen of onjuiste routeringsgegevens. Waar vind je dit? Binnenkomende SWIFT-berichten (MT103 RET, pacs.004) of de gpi-status RJCT. Vastleggen Vastgelegd wanneer een afwijzingsbericht is ontvangen Gebeurtenistype explicit
	Betaling overgedragen	Een tussentijdse statusupdate, vaak de gpi-status ACSP, die aangeeft dat een intermediaire bank de betaling verwerkt. Dit wordt vastgelegd via updates van de SWIFT gpi Tracker of statusberichten.
Waarom dit belangrijk is Geeft inzicht in de ‘black box’ van correspondentbankieren. Dit is belangrijk om de volledige reis van begin tot eind te analyseren. Waar vind je dit? Gegevensfeeds van de SWIFT gpi Tracker of MT199/trck-berichten. Vastleggen Vastgelegd wanneer een trackerupdate is ontvangen Gebeurtenistype explicit
	Betalingsfout opgelost	Een transactie die eerder een fout bevatte, is aangepast en opnieuw ingediend. Dit is af te leiden wanneer de transactie vanuit een wachtrij voor ‘Herstel’ teruggaat naar de status ‘In verwerking’ of ‘Klaar’.
Waarom dit belangrijk is Meet hoe efficiënt het team voor handmatig herstel werkt. Lange doorlooptijden wijzen op kennishiaten of complexe foutcodes. Waar vind je dit? Statuslogs van de Payment Hub die laten zien wanneer een transactie een uitzonderingswachtrij verlaat. Vastleggen Controleer of het statusveld ‘Herstel’ heeft verlaten Gebeurtenistype inferred
	Betalingsfout vastgesteld	Een transactie wordt gemarkeerd voor herstel vanwege mislukte validatie, NACK’s of afwijzingsberichten. Dit is af te leiden wanneer de transactie in een wachtrij voor ‘Herstel’, ‘Correctie’ of ‘Uitzonderingen’ terechtkomt.
Waarom dit belangrijk is Meet het percentage herstelwerk voor foutoplossing. Een hoge frequentie verlaagt het percentage volledig automatisch verwerkte betalingen (STP). Waar vind je dit? Statuskolommen van de Payment Hub of logs van uitzonderingswachtrijen. Vastleggen Controleer of het statusveld de waarde ‘Fout’ of ‘Herstel’ heeft Gebeurtenistype inferred
	Betalingsgegevens gevalideerd	De syntaxis- en opmaakcontroles van de betalingsopdracht zijn geslaagd, bijvoorbeeld de controle van het IBAN-formaat en de BIC. Dit is vaak af te leiden uit een statuswijziging van ‘Concept’ naar ‘Gevalideerd’ of ‘Klaar voor autorisatie’.
Waarom dit belangrijk is Veel mislukte controles wijzen op een slechte datakwaliteit bij de bron. Meet de KPI ‘Validatie in één keer goed’. Waar vind je dit? Statuslogs van de Payment Engine of validatiegeschiedenistabellen. Vastleggen Vergelijk het statusveld vóór en na de wijziging Gebeurtenistype inferred
	SWIFT-ACK ontvangen	De SWIFT-netwerkbevestiging (ACK) wordt ontvangen en bevestigt dat het bericht is geaccepteerd voor verwerking. Dit wordt rechtstreeks vastgelegd in de logs van de netwerkinterface.
Waarom dit belangrijk is Bevestigt dat het bericht het internationale netwerk heeft bereikt. Zo kun je interne fouten onderscheiden van problemen bij de verzending via het netwerk. Waar vind je dit? Logs van de SWIFT Gateway, met ACK- en NACK-signalen. Vastleggen Vastgelegd wanneer de netwerk-ACK is ontvangen Gebeurtenistype explicit

Aanbevolen Optioneel

Extractiegidsen

Zo haal je data uit SWIFT

Stappen

Log in op SWIFT Alliance WebPlatform of de Alliance Access-GUI met een beheerdersaccount dat toegang heeft tot de archiveringsinstellingen.
Ga naar het menu System Management, selecteer Archiving en kies Automated Archiving Configuration.
Stel een nieuw dagelijks exportprofiel in. Kies bij Target Directory een beveiligd netwerkpad dat toegankelijk is voor je extractiescripts.
Stel de inhoud in: selecteer 'Messages' en vink 'Include History' en 'Include Interventions' aan. Dit is nodig om gebeurtenissen in het auditspoor vast te leggen, zoals goedkeuringen en validaties.
Selecteer het uitvoerformaat. Kies XML, bij voorkeur 'SAA XML v2' of het nieuwste beschikbare schema. XML bewaart de hiërarchische relatie tussen de berichtkop en de geschiedenis beter dan CSV.
Stel de datumfilters in voor de historische periode die nodig is voor het process mining-project. Je kunt de export ook dagelijks laten uitvoeren voor T-1-data.
Voer de archiefexport handmatig uit voor de eerste gegevenslading, of wacht tot de geplande batchtaak is voltooid. Controleer of de .xml-bestanden in de doelmap staan.
De SAA-export is een hiërarchisch XML-bestand, terwijl ProcessMind een plat CSV-event log nodig heeft. Voer daarom een transformatiescript uit. Gebruik het Python-script uit het gedeelte Query om de XML te verwerken.
Het script doorloopt elk berichtelement. Het haalt de Unique End-to-end Transaction Reference (UETR) of het Transaction Reference Number (TRN) op en gebruikt dit als Case-ID.
Vervolgens doorloopt het script de onderliggende 'History'- en 'Intervention'-elementen van elk bericht om activiteitenregels te maken. Interne SAA-statuscodes, zoals 'NetworkAck' en 'Authorisation', worden gekoppeld aan gestandaardiseerde activiteitsnamen.
Voer het Python-script uit op de geëxporteerde XML-bestanden om het platte bestand 'events.csv' te maken.
Controleer de CSV-uitvoer. Zorg dat kolommen zoals EventTimestamp de ISO 8601-indeling gebruiken en upload het bestand daarna naar ProcessMind.

Configuratie

Archiefindeling: XML (aanbevolen) of CSV (plat bestand). XML wordt sterk aanbevolen om geneste geschiedenisgegevens vast te leggen.
Berichttekst opnemen: Ja (nodig om Amount, Currency en Beneficiary te verwerken).
Geschiedenis/interventies opnemen: Ja (vereist om goedkeuringen, validaties en fouten te zien).
Datumbereik: Stel een voortschrijdende periode in, bijvoorbeeld de laatste 30 dagen, voor incrementele gegevensladingen. Gebruik vaste datums voor de eerste historische gegevenslading.
Berichttypen: Filter op MT103, MT202, pacs.008, pacs.009 en pacs.004/002 (voor retouren/statussen).
Richting: Neem zowel inkomende (Emission) als uitgaande (Reception) berichten op om inkomende afwijzingen en bevestigingen vast te leggen.
Beveiliging: Zorg voor strikte lees- en schrijfrechten op de exportmap, omdat deze bestanden actuele betalingsdata bevatten.

a Voorbeeldquery 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}")

Stappen

De omgeving voorbereiden: Zorg dat Python 3.8 of hoger op de extractieserver is geïnstalleerd. Installeer de benodigde bibliotheken met pip (pandas, numpy). Maak een aparte werkmap met een submap raw_swift_files en plaats daarin alle dagelijkse .out-, .txt- of .fin-bestanden.
De bestandsstructuur controleren: Ruwe SWIFT FIN-berichten bestaan uit blokken ({1: Header} {2: Application} {4: Body}). Controleer de scheidingstekens. Standaardbestanden gebruiken accolades. Controleer of de bestanden niet in een eigen envelopformaat staan, zoals RJE-headers. Verwijder die zo nodig vóór de verwerking.
De scriptpaden instellen: Open het meegeleverde Python-script. Stel de variabele INPUT_DIRECTORY in op de map raw_swift_files. Stel ook het pad voor het uitvoerbestand in bij OUTPUT_FILE.
Regex-patronen instellen: Het script gebruikt regex om blokken te herkennen. Blok 1 bevat de BIC van de afzender en het volgnummer. Blok 2 bevat het berichttype, bijvoorbeeld I103 of O103, en de BIC van de ontvanger. Blok 4 bevat de tags met betalingsgegevens, zoals :20: TRN en :32A: waarde/bedrag.
Berichttypen aan activiteiten koppelen: Het script bevat een mappingtabel. MT103 staat voor 'Betalingsopdracht verzonden'. MT012 (System ACK) staat voor 'SWIFT-bevestiging ontvangen'. MT900/910 staat voor 'Betaling afgewikkeld'. MT199/299 met specifieke statuscodes (ACSP, RJCT) wordt gekoppeld aan 'Betaling overgemaakt' of 'Betaling afgewezen'.
Attributen ophalen: De parser doorloopt specifieke tags. :20: wordt gekoppeld aan Payment Transaction ID. :121: wordt gekoppeld aan UETR. :32A: wordt verwerkt als datum, valuta en bedrag.
Interne statussen verwerken: Activiteiten zoals 'Betalingsverzoek aangemaakt' of 'Betaling goedgekeurd' zijn vaak interne ERP-gebeurtenissen die niet in SWIFT-bestanden staan. Als er geen expliciete logs zijn, leidt het script deze af uit de berichtaanmaaktimestamp in blok 1. Het kan ook zoeken naar specifieke tekstcodes in veld :72: (Sender to Receiver Info), als je organisatie goedkeuringen daar registreert.
De extractie uitvoeren: Voer het script uit via de opdrachtregel: python swift_parser.py. Het script doorloopt alle bestanden, verwerkt geldige SWIFT-blokken en slaat ongeldige regels over.
De uitvoer controleren: Open het gegenereerde CSV-bestand. Controleer de indeling van EventTimestamp (ISO 8601 wordt aanbevolen). Controleer ook of PaymentTransactionId voor elke regel is ingevuld, zodat de cases kunnen worden gegroepeerd.
Data omzetten: Als 'ValueDate' de indeling YYMMDD heeft, zet het script deze om naar YYYY-MM-DD. Controleer of de decimaaltekens in 'TransactionAmount' overal hetzelfde zijn, met punten of komma’s.
Eindcontrole uitvoeren: Filter op een specifieke UETR om de volledige stroom te bekijken, van opdracht verzonden via ACK tot afwikkeling. Controleer of NAK’s (MT019) worden weergegeven als 'Betalingsfout vastgesteld'.
Uploaden naar ProcessMind: Importeer het CSV-bestand. Koppel PaymentTransactionId aan Case-ID, ActivityName aan Activiteit en EventTimestamp aan Timestamp.

Configuratie

Invoermap: Pad naar de map met ruwe FIN/MT-bestanden. Zorg dat leesrechten zijn ingesteld.
Datumnotatie verwerken: Ruwe SWIFT-datums gebruiken YYMMDD. Het script gaat uit van de eeuw 20xx.
Filters voor berichttypen: Het script richt zich op categorie 1 (betalingen), 9 (afschriften) en gangbare systeemberichten (012, 019). Pas de lijst RELEVANT_MT_TYPES aan als categorie 2 (overboekingen tussen financiële instellingen) nodig is.
Codering: Standaard wordt 'utf-8' gebruikt. Kies 'latin-1' of 'ascii' als de bestanden tekens uit een oudere codering bevatten.
Batchverwerking: Voor datasets groter dan 1 GB gebruikt het script een generator om geheugenproblemen te voorkomen. De bestanden worden één voor één verwerkt.
Regex aanpassen: De strikte regex gaat uit van de standaard FIN-indeling {1:...}{2:...}{4:...}. Gebruik je bestanden $ of andere scheidingstekens, pas dan de variabele BLOCK_PATTERN aan.

a Voorbeeldquery 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()

Stappen

Controleer of je een abonnement hebt op de SWIFT gpi Tracker API, of de API-inloggegevens en UETR-zoekfunctie beschikbaar zijn en of je toegang hebt tot de interne bron met betalingsgebeurtenissen. Haal de exacte API-basis-URL, authenticatiemethode, responsstructuur, snelheidslimieten en pagineringsregels op uit de SWIFT-servicedocumentatie. Ga niet uit van een vast endpointpad: dat hangt af van de SWIFT-dienst waarvoor je een licentie hebt en de implementatie.
Stel het script in met de vereiste verbindingsreeks, inloggegevens, datumbereik en filters voor jouw organisatie. Gebruik voor de eerste extractie een periode van drie tot zes maanden. Beperk de interne brondata tot betalingstransacties met een TRN of UETR en bewaar voor elke gebeurtenis de naam van het bronsysteem.
Haal de interne gebeurtenissen in de levenscyclus op voor Betalingsverzoek aangemaakt, Betalingsgegevens gevalideerd, Sanctiecontrole geslaagd, Betaling goedgekeurd, Betalingsopdracht verzonden, SWIFT-bevestiging ontvangen, Betalingsfout vastgesteld, Betalingsfout opgelost, Betaling afgewezen, Betaling afgewikkeld en Betaling gereconcilieerd. Zet elke brongebeurtenis om in een aparte regel in het event log. Laat ProcessMind geen activiteiten afleiden.
Haal UETR’s op uit de interne betalingsgegevens en bevraag voor elke UETR de SWIFT gpi Tracker API waarvoor je een licentie hebt. Gebruik de API-documentatie voor jouw omgeving om de aanvraag-URL, authenticatieheaders, parameters, paginering en responsvelden in te stellen. Bewaar de ruwe respons voor controle achteraf.
Zet relevante gpi-trackerstatussen om in expliciete gebeurtenisregels. Het script koppelt ACSP aan Betaling overgemaakt, RJCT aan Betaling afgewezen en ACSC aan Betaling afgewikkeld. Gebruikt de respons waarvoor je een licentie hebt andere statusnamen of timestamps, pas de statuskoppeling dan aan op basis van de gedocumenteerde responsstructuur. Maak geen gebeurtenis aan als de API geen overeenkomstige statusvermelding bevat.
Zet alle timestamps om naar één tijdzone, bij voorkeur UTC. Bewaar de oorspronkelijke timestamp als dat nodig is voor controledoeleinden. Zet geldbedragen om naar numerieke waarden, behoud de transactievaluta, normaliseer Booleaanse STP-waarden en laat waarden NULL als de bron geen attribuut bevat.
Verwijder dubbele gebeurtenissen op basis van PaymentTransactionId, ActivityName, EventTimestamp en de meest specifieke beschikbare brongebeurtenis-ID. Behoud meerdere geldige gebeurtenissen, zoals herhaalde herstel- en opnieuw-indieningscycli, tenzij de bedrijfsregel expliciet één gebeurtenis per activiteit voorschrijft.
Controleer of elke uitvoerregel PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem en LastDataUpdate bevat. Controleer of ActivityName alleen gedocumenteerde activiteitswaarden bevat en of alle 12 activiteiten voorkomen wanneer ze in de brondata aanwezig zijn.
Exporteer de dataset als UTF-8 CSV of een ander eventlogformaat dat ProcessMind ondersteunt. Gebruik één regel per gebeurtenis, neem de vereiste en aanbevolen kolommen op en koppel PaymentTransactionId aan de case-ID, ActivityName aan de activiteit en EventTimestamp aan de timestamp van de gebeurtenis. Upload het bestand naar ProcessMind. Verwacht niet dat er daarna nog gebeurtenissen worden afgeleid.

Configuratie

API-endpoint en schema: Stel de exacte basis-URL van de SWIFT gpi Tracker API, het resourcepad, de aanvraagparameters, authenticatieheaders, paginering en responsveldnamen in op basis van de SWIFT-documentatie voor jouw licentie en omgeving. Het script verzint bewust geen endpoint.
Inloggegevens en autorisatie: Gebruik de goedgekeurde methode voor SWIFT API-inloggegevens, vereisten voor certificaten of tokens, methode voor geheimenopslag en autorisaties voor interne bronsystemen. Zet productiegeheimen niet rechtstreeks in de broncode.
Datumbereik: Begin met drie tot zes maanden. Gebruik de timestamp van de gebeurtenis of de aanmaakdatum van de betaling die past bij je rapportagedoel. Verwerk grote volumes in kleinere perioden en sla op welke UETR’s zijn afgerond.
Filters voor interne bronnen: Stel filters in voor organisatie, juridische entiteit, vestiging, betalingsproduct, documenttype, berichttype, valuta en status, afgestemd op je systeem. Gebruik tijdelijke aanduidingen zoals [Configure based on your system] totdat het bronschema is bevestigd.
Activiteiten koppelen: Houd expliciete koppelingen bij voor interne statussen en wachtrijen. Voorbeelden: Draft koppelen aan Validated of Ready for Auth voor Betalingsgegevens gevalideerd; vrijgave uit Screening Hold voor Sanctiecontrole geslaagd; plaatsing in de Repair- of Exception-wachtrij voor Betalingsfout vastgesteld; en terugkeer naar Processing of Ready for Payment voor Betalingsfout opgelost.
gpi-statussen koppelen: Koppel gedocumenteerde trackerstatussen aan expliciete activiteiten. Deze implementatie koppelt ACSP aan Betaling overgemaakt, RJCT aan Betaling afgewezen en ACSC aan Betaling afgewikkeld. Breid de koppelingen alleen uit als de SWIFT API-documentatie waarvoor je een licentie hebt de betekenis van de status bevestigt.
Timestampbeleid: Zet timestamps waar mogelijk om naar UTC. Bepaal welke voorrang geldt voor de tijd van de brongebeurtenis, de trackergebeurtenis, de ontvangst van het bericht en de extractie. LastDataUpdate moet de extractie- of ververstijd aangeven, niet de tijd van de bedrijfsgebeurtenis.
Snelheidslimieten en nieuwe pogingen: Stel de time-out voor aanvragen, het aantal nieuwe pogingen, exponentiële wachttijd, verwerking van HTTP-statussen en paginering in. Houd rekening met de limieten van de SWIFT-dienst en voorkom ongecontroleerde parallelle aanvragen.
Prestaties: Sla responsen per UETR op, verwerk UETR’s in batches, bewaar voortgang en gebruik incrementele extractie als dat wordt ondersteund. Bevraag de tracker niet herhaaldelijk voor dezelfde UETR en periode.
Datakwaliteit: Vereis PaymentTransactionId, ActivityName, EventTimestamp, SourceSystem en LastDataUpdate. Aanbevolen attributen mogen NULL zijn als de bron ze niet bevat, maar rapporteer wel hoe vaak ze zijn ingevuld.
Controleerbaarheid: Bewaar de ruwe API-respons, aanvraagtijd, responsstatus, UETR en ID van de extractieronde op een goedgekeurde locatie voor controlegegevens. Volg de bewaartermijnen en beveiligingsregels voor betalingsdata.
Vereisten vooraf: Controleer of je toegang hebt tot logs van de interne betalingslevenscyclus, compliance, SWIFT-gateway, reconciliatie en berichteninterface. Controleer ook of je een licentie hebt voor de SWIFT gpi Tracker API en over eventuele vereiste certificaten of netwerktoegang beschikt.

a Voorbeeldquery 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()

Klaar om aan de slag te gaan?

Gebruik deze templates om ruwe SWIFT-logs om te zetten in een bruikbaar hulpmiddel voor betere bedrijfsvoering en snellere betalingsafwikkeling.

Terug naar de verbetergids Template downloaden

Verbeter nu de verwerking van SWIFT-betalingen

Bereik 98% straight-through processing en voorkom handmatige fouten

Start je gratis proefperiode

Geen creditcard nodig. Binnen 5 minuten ingesteld

De datatemplate voor betalingsverwerking

De datatemplate voor betalingsverwerking

Attributen voor betalingsverwerking

Activiteiten voor betalingsverwerking

Extractiegidsen

SWIFT Alliance Access-archiefexport

Stappen

Configuratie

a Voorbeeldquery python

Python-parser voor ruwe SWIFT MT-bestanden

Stappen

Configuratie

a Voorbeeldquery python

SWIFT gpi API-connector

Stappen

Configuratie

a Voorbeeldquery python

Klaar om aan de slag te gaan?

Verbeter nu de verwerking van SWIFT-betalingen

De datatemplate voor betalingsverwerking

De datatemplate voor betalingsverwerking

Attributen voor betalingsverwerking

Activiteiten voor betalingsverwerking

Extractiegidsen

SWIFT Alliance Access-archiefexport

Stappen

Configuratie

a Voorbeeldquery python

Python-parser voor ruwe SWIFT MT-bestanden

Stappen

Configuratie

a Voorbeeldquery python

SWIFT gpi API-connector

Stappen

Configuratie

a Voorbeeldquery python

Klaar om aan de slag te gaan?

Verbeter nu de verwerking van SWIFT-betalingen

We gaan zorgvuldig om met je privacy