Split json Nifi mit

Question

Ich habe eine json mit allen Datensätzen mit fusionierte Ich brauche die fusionierte json und Last in separaten Datenbank mit Nifi

Meine Datei zu teilen, wenn ich

db.collection.findOne()

Mein ausführen Eingabe sieht wie aus:

[ 
    { 
    "name": "sai", 
    "id": 101, 
    "company": "adsdr" 
    }, 
    { 
    "name": "siva", 
    "id": 102, 
    "company": "shar" 
    }, 
    { 
    "name": "vanai", 
    "id": 103, 
    "company": "ddr" 
    }, 
    { 
    "name": "karti", 
    "id": 104, 
    "company": "sir" 
    } 
] 

Ich bekomme alle JSON. Ich muss erhalten Ausgabe als:

{name: sai, I'd:101, company: sdr}

so dass ich nur ein aufnehmen wollen, wie kann ich die json mit Nifi analysieren?

Answer 1

Es gibt einen SplitJson Prozessor für diesen Zweck:

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.SplitJson/index.html

Es gibt verschiedene JSON Pfad Tester online mit dem richtigen Ausdruck zu kommen:

https://jsonpath.curiousconcept.com/

Answer 2

Als Bryan sagte Sie können SplitJson processor verwenden. Und dann können Sie den geteilten Datenfluss an die anderen Datenbanken weiterleiten.

Der Prozessor intern verwendet this json Pfadfinder. Sie können in der Dokumentation nachlesen, welche Operationen unterstützt werden.

Gerade diese verwenden das erste Element zu erhalten, indem:

// JSON Path Expression for the first element: 
$[0] 

[ 
    { 
    "name": "sai", 
    "id": 101, 
    "company": "adsdr" 
    } 
] 

Answer 3

Verwenden Split json Prozessor mit folgenden Konfigurationen, wie im Screenshot unten gezeigt

SplitJson Config