FLiP - IoT Examples with Go, Java, MiNiFi, Flink, Pulsar, StreamNative, JSON FLiP = Apache FLink integrated with Apache Pulsar. (And sometimes Apache NiFi and other Apache friends)
https://github.com/streamnative/examples/tree/master/cloud/java
https://github.com/streamnative/examples/tree/master/cloud/go
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-arm64
update-alternatives --list java
/usr/lib/jvm/java-8-openjdk-arm64
go mod tidy
https://github.com/hpcloud/tail
go get github.com/hpcloud/tail/... go mod tidy
./iot -serviceURL pulsar+ssl://istnace.streamnative.cloud:6651
-privateKey instance-key.json
-audience urn:sn:pulsar:tenant:instance
-issuerUrl https://auth.streamnative.cloud\
-clientId SOMECLIENTIDFORSTREAMNATIVE
#!/bin/bash
DATE=$(date +"%Y-%m-%d_%H%M") python3 -W ignore /home/nvidia/nvme/minifi-jetson-xavier/demo.py --camera /dev/video0 --network googlenet /home/nvidia/nvme/images/$DATE.jpg 2>/dev/null
go build -o iot iotproducer.go
./iotlocal
bin/pulsar-client consume "persistent://public/default/nvidia-sensor-partition-0" -s "nano2gbgo" -n 0
python2 sensors.py