Streaming-Plattform einrichten

Unter Windows

Anweisungen für die manuelle Einrichtung der Streaming-Plattform unter Windows sind derzeit nicht vorhanden.

Es wird empfohlen, die Linux-Installation in einer Produktionsumgebung zu verwenden.

Hinweis: Wenn Sie die Streaming-Plattform unter Windows ausprobieren möchten, verwenden Sie ONE Installer, um ein Einzelknoten-System einzurichten.

Weitere Informationen finden Sie unter: ONE Installer - Single-Box-Installation

Unter Linux

Führen Sie diese Schritte aus, um die Streaming-Plattform einzurichten.

Schritt 1: Laden Sie die benötigte Zip-Datei von ca.com herunter

Melden Sie sich auf der Support-Seite an und klicken Sie auf Download Management.
Geben Sie über die Suchleiste CA Automic ein, gefolgt von dem Paket, das Sie herunterladen möchten.

Beispiel: Automic Automation

Nachdem Sie die Datei heruntergeladen haben, entpacken Sie sie in ein temporäres Verzeichnis.
Suchen Sie die Datei kafka tgz im folgenden Verzeichnis: <Automic>/External.Resources/kafka.
Entpacken Sie die Datei kafka tgz. Diese Datei wird in Schritt 2 auf das Ziel-Installationssystem kopiert werden.

Schritt 2: Die Streaming-Plattform starten

Erstellen Sie auf der Zielinstallationsmaschine ein neues Verzeichnis, das folgendermaßen aussieht: <automic>/External.Resources/kafka.
Kopieren Sie den Inhalt der kafka tgz-Datei in das Verzeichnis: <automic>/External.Resources/kafka. Das Verzeichnis sollte folgendermaßen aussehen:

bin

config

libs

site-docs

NOTICE

Kopieren Sie das folgende Script in Editor (oder einen Texteditor) und speichern Sie es als start.sh im folgenden Verzeichnis: <Automic>/External.Resources/kafka/bin.

Wichtig!

Beachten Sie, dass Sie im folgenden Script die Variable %JDK% durch Ihren aktuellen jdk-Pfad ersetzen müssen.
Ersetzen Sie die Variable %ZOOKEEPER_CONNECT% durch den aktuellen [host]:[port] von Zookeeper (z. B. ist der Standard localhost:2181).

#!/usr/bin/env bash
echo Starting up Zookeeper

stop_kafka() {
    echo Stopping kafka > kafka_stop.out
    ./kafka-server-stop.sh
    echo Stopping zookeeper >> kafka_stop.out
    ./zookeeper-server-stop.sh
    echo Shutdown finished >> kafka_stop.out
    exit
}

trap stop_kafka SIGHUP SIGINT SIGTERM SIGUSR1 SIGKILL

export JAVA_HOME=%JDK%
export PATH=${JAVA_HOME}/bin:$PATH

./zookeeper-server-start.sh ../config/zookeeper.properties > zookeeper.out 2>&1 &

while true
do
  cmd=$(ps aux | grep "$JAVA_HOME/bin/java.*zookeeper-gc\.log.*" | grep -v "grep" | wc -l)
  echo $cmd
  if [ $cmd -ge 1 ]
    then
      echo Zookeeper is running
      break
    else
      echo NOT RUNNING
      sleep 1
  fi
done

# ein paar zusätzliche Sekunden sleep, um sicherzustellen, dass der Port tatsächlich verfügbar ist 
sleep 4
./zookeeper-shell.sh %ZOOKEEPER_CONNECT% rmr /brokers
./kafka-server-start.sh ../config/server.properties > kafka.out 2>&1 &

while true
do
    sleep 1
done

Erstellen Sie im Verzeichnis Automic/External.Resources/kafka ein neues Unterverzeichnis namens zk-tmp. Dieses Verzeichnis enthält alle Ihre Zookeeper-Datendateien.
Öffnen Sie die Datei zookeeper.properties, die sich hier befindet: <automic>/External.Resources/kafka/config. Suchen Sie den Parameter dataDir und bearbeiten Sie ihn, um das neu erstellte zk-tmp-Verzeichnis zu berücksichtigen.

Beispiel: dataDir=/automic/External.Resources/kafka/kafka/zk-tmp
Machen Sie im Verzeichnis <automic>/External.Resources/kafka/bin unter als Root-Benutzer die Datei ausführbar, dazu führen Sie beispielsweise den Befehl chmod +x ./Start.sh aus.

Schritt 3: Die Streaming-Plattform zur SMD-Datei des Service Managers hinzufügen

Hinweis: Für die Schritte 3 und 4 müssen Sie den Service Manager installiert haben. Wenn der Service Manager nicht installiert ist, lesen Sie unter den folgenden Links nach: ServiceManager, Startparameter - ServiceManager.

Wenn Sie den Service Manager installiert haben, öffnen Sie die Datei uc4.smd, die Sie hier finden: <automic>/Automation.Platform/ServiceManager/bin/uc4.smd. Fügen Sie unter Verwendung Ihres definierten Verzeichnispfades eine DEFINE STREAMING-PLATFORM-Zeile hinzu, wie im folgenden Beispiel gezeigt:

DEFINE STREAMING-PLATFORM;<automic>/External.Resources/kafka/kafka/bin/start.sh;

<automic>/External.Resources/kafka/kafka/bin

Schritt 4: Die Streaming-Plattform zur SMC-Datei des Service Managers hinzufügen

Öffnen Sie die Datei uc4.smc, die Sie hier finden:<automic>/Automation.Platform/ServiceManager/bin/uc4.smc und fügen Sie die folgenden beiden Zeilen ein (fett ausgezeichnet). Schließen Sie den Service Manager und starten Sie ihn anschließend neu oder starten Sie den STREAMING-PLATTFORM-Service neu:

WAIT 10

CREATE RULE-ENGINE

WAIT 3

CREATE ANALYTICS-DATASTORE

WAIT 14

CREATE ANALYTICS-BACKEND

WAIT 3

CREATE STREAMING-PLATFORM

Schritt 5: Die Konfigurationsdatei anpassen

Hinweis:Analytics Dieser Schritt kann erst abgeschlossen werden, wenn Sie das Backend installiert haben. Wenn Sie dies nicht getan haben, beachten Sie die folgende Host- und Portkonfiguration.

In der Konfigurationsdatei application.properties müssen einige Anpassungen vorgenommen werden. Diese Datei finden Sie hier: <automic>/Automation.Platform/Analytics/backend/application.properties:

Stellen Sie die Kommunikationsparameter für das Backend ein, um mit Kafka zu kommunizieren:

kafka.bootstrap_servers=hostIP:9092

Hinweis: Die HostIP und der Port sehen die Maschine, auf der Kafka installiert ist.

Legen Sie die Kommunikationsparameter fest, mit denen das Backend mit Zookeeper kommunizieren soll:

zookeeper.bootstrap_servers=hostIP:2181

Hinweise:

HostIP und Port überprüfen die Maschine, auf der Zookeeper installiert ist.
Wenn Sie die Event Engine-Funktion verwenden und die Streaming-Plattform nicht mehr verfügbar ist, schlagen Regeln, die auf der Rule Engine ausgeführt werden, nach einem Timeout fehl. Der Standard-Timeout beträgt 5 Minuten (305000 Millisekunden) und kann bei Bedarf angepasst werden. Um den Timeout zu ändern, konfigurieren Sie Folgendes:

kafka.consumer_configs.edda_events[request.timeout.ms]=305000

Schritt 6: Die Streaming-Plattform sichern (optional)

Weitere Informationen finden Sie unter: TLS/SSL-Einrichtung zwischen Backend und Streaming-Plattform