Edge Open Demo Project

Edge Gateway (based on RHEL with Microshift preinstalled)

To use the prebuilt image, create a VM using the provided ISO as installation disk found ftp link[¹]
As operating system select RHEL8.6, create a VM with the disk image as the ISO and make sure to select EUFI as boot loader, provide at least 4GB of RAM and choose automatic partioning
Username and password of default admin user are admin:password
After the installation Microshift should be running already, you can check with:

systemctl status microshift

You would need to install oc or kubectl to access the cluster:

curl -O https://mirror.openshift.com/pub/openshift-v4/$(uname -m)/clients/ocp/stable/openshift-client-linux.tar.gz
sudo tar -xf openshift-client-linux.tar.gz -C /usr/local/bin oc kubectl

and copy the kubeconfig file:

mkdir ~/.kube
sudo cat /var/lib/microshift/resources/kubeadmin/kubeconfig > ~/.kube/config

Now you should be able to access the microshift cluster.

[¹]: need a wget to resolve the actual link

OKD console on Microshift

If you don't like the standard k8s dashboard you can also deploy the OKD console (v4) on top of it as shown here
and then access the console at http://localhost:30036/dashboards

Remote access to Microshift

First of all, make sure you opened port 6443 on the firewall of the Edge device to allow external access

Deploy Flotta to manage workloads on Microshift

https://project-flotta.io/documentation/v0_2_0/gsg/ocp.html

MQTT Broker

The broker is based on Apache Artemis MQ project
We will be using this qoricode/activemq-artemis image to create a statefulset and service

kubectl create -f svc-artemis.yaml
kubectl create -f ss-artemis.yaml

By default persistence is enabled and all protocol ports are exposed (port 8161 dedicated to web console and port 1883 dedicated to mqtt protocol)
Username and password to access the web console are artemis:simetraehcapa

Data caching

For persisting partial results (and state in case of failure) we will be using Infinispan
We will be installing it using Helm charts
You can find the chart values here

helm install infinispan -n default openshift-helm-charts/infinispan-infinispan --values infinispan-values.yaml

Geo query

For the geo query functionality we are going to rely on Redis
We will install the component using Helm charts with the following parameters:

helm repo add bitnami https://charts.bitnami.com/bitnami
helm repo update
helm install my-redis -n default --set auth.password=password --set master.persistence.storageClass=kubevirt-hostpath-provisioner --set architecture=standalone --set replica.replicaCount=0 --set metrics.enabled=true bitnami/redis

If you want to connect from outside make sure to expose redis svc as NodePort

Sample data from the sensor

To test the full flow you can append the following payload to the topic previosuly created (and configured on quarkus app)

{
    "sensor":"truck1",
    "pressure":1007.05,
    "temperature":28.60751343,
    "humidity":51.09419632,
    "gas_resistance":7.362,
    "altitude":51.83121109,
    "gps":[48.75608,2.302038],
    "CO2":421,
    "ppm":3
}

Packaging and running the application on Microshift

Since Microshift is not implementing Build or BuildConfig OpenShift APIs, we would need a 2 steps approach to deploy the Quarkus application on it:

1. build the container image and push it to Quay (as configured inside the application.properties file)

   mvn clean package -DskipTests -Dquarkus.container-image.push=true -Dquarkus.container-image.password=<your_quay_password>
   

2. use the generated k8s deployment artifact and create the deployment, while connected to the Edge device

   kubectl create -f kubernetes.yml
   

whenever you update the image and want to redeploy the application to use the latest version of the image, you can execute the following

kubectl rollout restart deployment your_deployment_name

Testing the application workflow

Send the above JSON payload at least 6 times and it should trigger the first level alerting (remember to click on profile inside artemis console before trying to send a message to authorize the console user)
Head to the test mail server and search for [email protected] and you should see the alert email
Create a telegram bot and retrieve the authorization token, then create a public chat group with the bot and identify the chat_id of the group that will be used for telegram notifications (you can call the following api to retrieve the chat_id: https://api.telegram.org/botXXX:YYYY/getUpdates)

---

Running the application in dev mode

You can run your application in dev mode that enables live coding using:

./mvnw compile quarkus:dev

NOTE: Quarkus now ships with a Dev UI, which is available in dev mode only at http://localhost:8080/q/dev/.

Packaging and running the application

The application can be packaged using:

./mvnw package

It produces the quarkus-run.jar file in the target/quarkus-app/ directory. Be aware that it’s not an über-jar as the dependencies are copied into the target/quarkus-app/lib/ directory.

The application is now runnable using java -jar target/quarkus-app/quarkus-run.jar.

If you want to build an über-jar, execute the following command:

./mvnw package -Dquarkus.package.type=uber-jar

The application, packaged as an über-jar, is now runnable using java -jar target/*-runner.jar.

Creating a native executable

You can create a native executable using:

./mvnw package -Pnative

Or, if you don't have GraalVM installed, you can run the native executable build in a container using:

./mvnw package -Pnative -Dquarkus.native.container-build=true

You can then execute your native executable with: ./target/code-with-quarkus-1.0.0-SNAPSHOT-runner

If you want to learn more about building native executables, please consult https://quarkus.io/guides/maven-tooling.

Related Guides

• Camel Log (guide): Log messages to the underlying logging mechanism
• Camel Core (guide): Camel core functionality and basic Camel languages: Constant, ExchangeProperty, Header, Ref, Simple and Tokenize
• Camel ActiveMQ (guide): Send messages to (or consume from) Apache ActiveMQ. This component extends the Camel JMS component
• Camel HTTP (guide): Send requests to external HTTP servers using Apache HTTP Client 4.x