2017-11-01 1 views
0

Ich versuche, einige Daten von meinem lokalen rethinkdb mit Apache Nifi mit GetRethinDB Prozessor zu greifen. Es zeigt mir einen Konfigurationsfehler, dass die Upstream-Verbindungseinstellung ungültig ist. Kann mir jemand helfen zu verstehen, was es bedeutet und wie man darüber hinwegkommt? Gibt es einen anderen Prozessor, den ich in Verbindung damit benutzen sollte?Apache Nifi GetRethinkDB Upstream-Verbindung ungültig

Dank

Neil

Antwort

2

Die meisten „GetXYZ“ Prozessoren sind „source-Prozessoren“, das heißt, sie werden erwartet, um Daten für die Strömung zu erzeugen und damit eingehende Verbindungen nicht akzeptieren (deren Daten-Upstream erzeugt werden muss,).

Um dies zu verringern, wird das ListXYZ -> FetchXYZ-Muster verwendet, hier gibt es zwei separate Prozessoren, einer (ListXYZ) ist ein Quellprozessor, der nur Informationen über die "XYZ" erhält, die verfügbar sind. Dann akzeptiert FetchXYZ eine eingehende Verbindung und verwendet die Information (normalerweise in einem Flussdateiattribut), um tatsächlich die XYZ-Ressource zu erhalten. Mithilfe dieses Musters können Sie ListXYZ durch einen anderen Upstream-Fluss/Prozessor ersetzen, um Informationen darüber bereitzustellen, welche Ressourcen an den FetchXYZ-Prozessor abgerufen werden müssen.

Nach alledem gibt es zur Zeit keine ListRethinkDB -> FetchRethinkDB-Prozessoren. Wenn RethinkDB über einen JDBC-Treiber verfügte (was meiner Meinung nach aufgrund der Natur seines Datenmodells und seines Abfragemodells nicht der Fall ist), könnten Sie die "SQL" -Prozessoren verwenden, um die Daten abzurufen.

Lange Rede, kurzer Sinn, ich glaube nicht, dass es im Moment einen Workaround gibt. Fühlen Sie sich frei, eine New Feature Jira für List/FetchRethinkDB oder was auch immer zu schreiben, und besonders frei, sie zu implementieren und sie zurück zur Gemeinschaft beizutragen! ;)

+0

vielen dank !!! ich werde das machen.. – nelalx