EDI: Transformări EDIFACT cu Python (bots-edi, pyx12) – rețete gata de folosit

În ultimul an, presiunea pentru automatizarea fluxurilor B2B a crescut vizibil în retail și automotive, iar standardul EDIFACT rămâne coloana vertebrală a schimbului electronic de documente în Europa. Pentru echipele tehnice care vor să reducă time-to-integration și costurile de licențiere, Python oferă o combinație solidă: orchestrare și mapare cu bots-edi pentru EDIFACT și validare/generare pentru tranzacții X12 cu pyx12, atunci când există parteneri din SUA. Mai jos sunt rețete gata de folosit pentru a transforma rapid ORDERS, DESADV și INVOIC, împreună cu contexte reale de piață.

De ce acum: context de piață și adopție EDI

Conform Mordor Intelligence, piața globală EDI a fost estimată la aproximativ 2,29 miliarde USD în 2024 și este proiectată să atingă circa 3,46 miliarde USD până în 2029 (CAGR ~8,8%). În Europa, EDIFACT/EANCOM domină retailul (Carrefour, Tesco, Ahold Delhaize, Metro) și supply chain-ul auto (Volkswagen Group, Stellantis, Bosch), unde EDI livrează consistență și conformitate între sute de furnizori. În SUA, Walmart și Amazon Vendor Central cer în mod curent EDI (de obicei X12), dar pentru entitățile europene canalele EDIFACT (ORDERS, DESADV, INVOIC) sunt standardul de facto.

Stack recomandat: bots-edi, pyx12 și o schemă canonică JSON

• bots-edi: translator EDI open source scris în Python, suport pentru EDIFACT/EANCOM, X12, TRADACOMS, XML; ideal pentru rute, mapări și monitorizare. Rulează on-prem sau containerizat și se integrează bine cu ERP-uri via API/CSV/DB.
• pyx12: librărie Python focalizată pe X12 (validare, mapare și conversii). Nu parsează EDIFACT, dar e utilă când trebuie să convertiți EDIFACT spre X12 sau să validați mesaje X12 într-un proiect mixt EDI.
• JSON canonic: un model intern (order, shipment, invoice) care decuplează EDIFACT de ERP. Simplifică întreținerea când partenerii EDI schimbă versiuni/guideline-uri.

Rețetă 1: EDIFACT ORDERS (EANCOM) -> JSON canonic în Python

Folosim un parser ușor pentru a extrage câmpurile esențiale (număr comandă, date, linii, cantități). Exemplul de mai jos ilustrează ideea; în producție, completați mapping-ul conform guideline-ului partenerului EDI (ex. GS1 EANCOM 2002/2007):

# pip install pydifact

from pydifact.segmentcollection import SegmentCollection

import json
def edifact_orders_to_json(edifact_str: str) -> dict:

    sc = SegmentCollection.from_str(edifact_str)

    order = {"order_number": None, "date": None, "buyer": None, "supplier": None, "lines": []}

    current_line = None
for seg in sc.segments:

        if seg.tag == "BGM":

            # BGM+220+ORDERNO+9'

            order["order_number"] = seg.elements[1] if len(seg.elements) > 1 else None

        elif seg.tag == "DTM":

            # DTM+137:20250120:102'

            if seg.elements and seg.elements[0].startswith("137:"):

                parts = seg.elements[0].split(":")

                order["date"] = parts[1]

        elif seg.tag == "NAD":

            # NAD+BY+...  (Buyer), NAD+SU+... (Supplier)

            if seg.elements and seg.elements[0] == "BY":

                order["buyer"] = seg.elements[1] if len(seg.elements) > 1 else None

            if seg.elements and seg.elements[0] == "SU":

                order["supplier"] = seg.elements[1] if len(seg.elements) > 1 else None

        elif seg.tag == "LIN":

            # LIN+1++GTIN:SRV'

            if current_line:

                order["lines"].append(current_line)

            current_line = {"line_no": seg.elements[0] if seg.elements else None, "gtin": None, "qty": None, "uom": None}

        elif seg.tag == "PIA" and current_line:

            # PIA+1+GTIN:SRV'

            if seg.elements and len(seg.elements) > 1 and ":" in seg.elements[1]:

                current_line["gtin"] = seg.elements[1].split(":")[0]

        elif seg.tag == "QTY" and current_line:

            # QTY+21:100'

            if seg.elements and seg.elements[0].startswith("21:"):

                q = seg.elements[0].split(":")

                current_line["qty"] = int(q[1])

        elif seg.tag == "UNT":

            if current_line:

                order["lines"].append(current_line)

                current_line = None
return order
# Exemplu de folosire:

# result = edifact_orders_to_json(open("orders.edi").read())

# print(json.dumps(result, indent=2, ensure_ascii=False))

Integrați funcția într-un worker care citește dintr-un inbox SFTP/AS2 și publică JSON-ul într-un API ERP. Într-un setup enterprise, bots-edi poate orchestra rutele (inbound EDIFACT -> Python mapping -> outbound REST), cu loguri, retry și monitorizare – un plus major pentru operațiuni EDI 24/7.

Rețetă 2: EDIFACT DESADV -> CSV/DB pentru WMS

Pentru WMS, multe echipe preferă o inserție directă în DB sau un CSV simplu. Refolosiți parserul și scrieți exportul cu header fix:

import csv
def desadv_to_csv(edifact_str: str, csv_path: str):

    sc = SegmentCollection.from_str(edifact_str)

    rows, shipment_id = [], None
for seg in sc.segments:

        if seg.tag == "BGM":  # BGM+351+ASNNO'

            shipment_id = seg.elements[1] if len(seg.elements) > 1 else None

        elif seg.tag == "LIN":

            line_no = seg.elements[0] if seg.elements else None

            rows.append({"shipment": shipment_id, "line_no": line_no, "gtin": None, "qty": None})

        elif seg.tag == "PIA" and rows:

            if ":" in seg.elements[1]:

                rows[-1]["gtin"] = seg.elements[1].split(":")[0]

        elif seg.tag == "QTY" and rows:

            if seg.elements and seg.elements[0].startswith("12:"):  # 12 = despatched quantity

                rows[-1]["qty"] = int(seg.elements[0].split(":")[1])
with open(csv_path, "w", newline="") as f:

        writer = csv.DictWriter(f, fieldnames=["shipment", "line_no", "gtin", "qty"])

        writer.writeheader()

        writer.writerows(rows)

Rețetă 3: INVOIC EDIFACT -> X12 810 cu pyx12 (pentru parteneri din SUA)

Când trebuie să convertiți o factură EDIFACT într-un 810 X12, folosiți același JSON canonic drept punte. Generați segmentarea X12 și validați rezultatul cu pyx12. Atenție: pyx12 lucrează cu X12, nu cu EDIFACT, deci maparea EDIFACT→JSON→X12 este a voastră.

# pip install pyx12

from pyx12.params import params

from pyx12.map_if import compliance_check

from pyx12.x12file import X12Writer
def build_x12_810(json_invoice, target_path):

    with open(target_path, "w") as f:

        w = X12Writer(f, "~", "*", ">")

        # ISA/GS/… ST segments (simplificat):

        w.write_segment("ISA", ["00","          ","00","          ","ZZ","SENDERID   ","ZZ","RECEIVERID ","240201","1234","U","00401","000000905","0","P",":"])

        w.write_segment("GS", ["IN","SENDERID","RECEIVERID","20240201","1234","1","X","004010"])

        w.write_segment("ST", ["810","0001"])

        # BIG (date și număr factură)

        w.write_segment("BIG", [json_invoice["invoice_date"], json_invoice["invoice_number"]])

        # N1, IT1 etc. (exemplu minimal)

        for line in json_invoice["lines"]:

            w.write_segment("IT1", [line["line_no"], line["qty"], "EA", line["price"], "VP", line["sku"]])

        w.write_segment("SE", ["10","0001"])

        w.write_segment("GE", ["1","1"])

        w.write_segment("IEA", ["1","000000905"])
# După generare, validați cu pyx12 (map-uri X12 corespunzătoare versiunii partenerului):

# from pyx12.error_handler import ErrhNull

# compliance_check(open("out.810").read(), params(), ErrhNull())

Validați întotdeauna cu guideline-ul partenerului EDI (versiuni 004010/005010 etc.). pyx12 ajută la conformitate X12; pentru EDIFACT rămâneți în bots-edi sau în parserul vostru.

Operaționalizare: monitorizare, SLA și costuri

• Monitorizare: bots-edi oferă dashboard cu status pe mesaje, reîncercări, alerte; integrați cu Prometheus/Grafana pentru vizibilitate end-to-end EDI.
• Conectivitate: AS2/SFTP/Peppol, certificate și rotație chei; segmentați canalele EDI pe partener și tip mesaj pentru izolare.
• Costuri: open source minimizează OPEX, însă bugetați 20–30% timp pentru întreținerea mapping-urilor când partenerii schimbă guideline-urile EDI.

Cazuri reale și bune practici

Retailerii europeni precum Carrefour și Metro folosesc intens EANCOM (ORDERS, DESADV, INVOIC). În automotive, Volkswagen Group și Bosch operează volume mari EDIFACT pe rute just-in-time. Pentru acești vectori, stabilitatea canalelor EDI contează mai mult decât inovația vizibilă – standardele sunt stricte, iar validarea și testele automate pe fiecare mapping salvează nenumărate ore. Dacă preferați un furnizor gestionat în România, puteți evalua și opțiuni locale (de ex., EDIconnect.ro ca modul CRMconnect) pentru a externaliza transportul/AS2 și a păstra mapping-ul în Python.

Concluzie

Cu bots-edi pentru fluxuri EDIFACT, pyx12 pentru X12 și un model JSON canonic la mijloc, echipele IT câștigă viteză și control asupra integrărilor EDI. Rețetele de mai sus pot fi puse rapid în producție și scalate pe măsură ce extindeți rețeaua de parteneri. Într-o piață în creștere, unde EDI susține operațiuni critice și SLA-uri stricte, investiția într-un toolchain Python bine pus la punct oferă combinația rară dintre costuri reduse, flexibilitate și guvernanță solidă.