Dieses Szenario soll Sie bei der Einrichtung und Verwendung von Konnektoren in einer Pipeline unterstützen. Es wird empfohlen, dass Sie das Szenario an Ihre Umgebung und Ihren Anwendungsfall anpassen.
Prozedur
Klicken Sie auf Connections (Verbindungen) > Add connection (Verbindung hinzufügen).
Wählen Sie den Typ der zu erstellenden Verbindung im daraufhin geöffneten Fenster aus.
Example
REST
Wählen Sie in der Liste Engine Ihre Engine aus.
InformationshinweisAnmerkung:
Es wird empfohlen, die Remote Engine Gen2 und nicht die Cloud Engine for Design für eine erweiterte Datenverarbeitung einzusetzen.
Wenn keine Remote Engine Gen2 in Talend Management Console erstellt wurde bzw. diese vorhanden, aber als nicht verfügbar markiert ist, d. h. sie ist nicht aktiv und wird nicht ausgeführt, dann können Sie weder einen Connection type (Verbindungstyp) in der Liste auswählen noch die neue Verbindung speichern.
Die Liste der verfügbaren Verbindungstypen richtet sich nach der ausgewählten Engine.
Wählen Sie den Typ der zu erstellenden Verbindung aus.
Wählen Sie in diesem Fall REST aus.
Geben Sie die Verbindungseigenschaften und die URL-Adresse für den Aufruf des REST-Servers wie in Eigenschaften von REST beschrieben ein, prüfen Sie die Verbindung und klicken Sie dann auf Add dataset (Datensatz hinzufügen). In diesem Beispiel wird der Dienst https://opendata.paris.fr/api/datasets/1.0/ aufgerufen, der offene Daten zu Paris angibt.
Geben Sie im Fensterbereich Add a new dataset (Neuen Datensatz hinzufügen) einen Namen für Ihren Datensatz ein. Der REST-Konnektor gibt eine JSON mit geparstem Body-Eintrag zurück.
Example
Paris road traffic (Straßenverkehr in Paris)
Geben Sie die erforderlichen Eigenschaften ein, um den Dienst aufzurufen, und klicken Sie auf View sample (Sample anzeigen), um eine Vorschau des Datensatz-Samples anzuzeigen:
Wählen Sie im Feld Type (Typ) den Eintrag Batch aus, da der Dienst nur einmal aufgerufen werden soll.
Geben Sie im Feld Resource (Ressource)search (Suchen) ein.
Wählen Sie im Feld HTTP method (HTTP-Methode) die Methode GET aus.
Wählen Sie im Feld Answer body format (Format des Antwort-Bodys) das Format Text aus.
Aktivieren Sie die Option Set URL parameter (URL-Parameter festlegen) und fügen Sie die Abfrageparameter hinzu: dataset (Datensatz - Parameter) und referentiel-comptages-routiers (Referenz Zählung Straßenverkehr - Wert).
Klicken Sie auf Validate (Validieren), um den Datensatz zu speichern.
Gehen Sie genauso vor, um den Testdatensatz hinzuzufügen, der als Ziel in Ihrer Pipeline für den Empfang von Logs verwendet werden soll. Geben Sie die Verbindungseigenschaften gemäß der Beschreibung in Eigenschaften der Testverbindung ein.
Klicken Sie auf der Seite Pipelines auf Add pipeline (Pipeline hinzufügen). Ihre neue Pipeline wird geöffnet.
Legen Sie einen sinnvollen Namen für die Pipeline fest.
Example
From Http Rest to Log output - invoke & process (Von HTTP-REST zu Log-Ausgabe - Aufrufen und Verarbeiten)
Klicken Sie auf ADD SOURCE (QUELLE HINZUFÜGEN) und wählen Sie Ihren Quelldatensatz, Paris road traffic (Straßenverkehr in Paris), im daraufhin geöffneten Fenster aus.
Klicken Sie auf das Element ADD DESTINATION (ZIEL HINZUFÜGEN) für die Pipeline, um das Fenster zur Auswahl des Ausgabedatensatzes zu öffnen, in dem die Ausgabelogs gespeichert werden sollen.
Aktivieren Sie auf der Registerkarte Configuration (Konfiguration) des Ziels die Option Log records to STDOUT (Datensätze in STDOUT protokollieren), um die Logs in das Ausgabeziel aufzunehmen.
Klicken Sie auf Save (Speichern), um die Konfiguration zu speichern.
Klicken Sie in der oberen Symbolleiste von Talend Cloud Pipeline Designer auf die Schaltfläche Run (Ausführen), um das Fenster zur Auswahl des Ausführungsprofils zu öffnen.
Wählen Sie Ihr Ausführungsprofil in der Liste aus (weitere Informationen finden Sie unter „Ausführungsprofile“) und klicken Sie dann auf Run (Ausführen), um die Pipeline auszuführen.
Ergebnisse
Ihre Pipeline wird ausgeführt, die aus dem REST-API-Dienst abgerufenen Daten wurden verarbeitet und die Ausgabelogs werden in dem von Ihnen definierten Zieldatensatz gespeichert.
Hat diese Seite Ihnen geholfen?
Wenn Sie ein Problem mit dieser Seite oder ihrem Inhalt feststellen, sei es ein Tippfehler, ein ausgelassener Schritt oder ein technischer Fehler, informieren Sie uns bitte!
