The Trucking IoT project is a modern real-time streaming application serving as a reference framework for developing a big data pipeline, complete with a broad range of use cases and powerful reusable core components.

Modern applications can ingest data and leverage analytics in real-time. These analytics are based on machine learning models typically built using historical big data. This reference application provides examples of connecting data-in-motion analytics to your application based on Big Data.

From IoT sensor data collection, to flow management, real-time stream processing and analytics, through to machine learning and prediction, this reference project aims to demonstrate the power of open source solutions.

• Prerequisites
• Quick, How Do I Use It?!
• Setup on existing HDF/HDP
• How It Works

• An instance of the Hortonworks HDF Sandbox.
• (or, alternatively) Your own Ambari-powered cluster with ZooKeeper, NiFi, Storm and Kafka
• For integration with Schema Registry, download and run the single-script setup located at: https://github.com/orendain/schema-registry-setup

For an instance of the HDF Sandbox preloaded with this reference application, run the following Docker command below.

Note: Please make sure Docker has at least 8GB of memory before running the container below.

For a Nifi -> Storm -> Nifi -> Kafka -> Web Application pipeline, with integration with Hortonworks Schema Registry:

docker run --name hdf-trucking-iot --hostname "sandbox.hortonworks.com" --privileged -d \
-p 12181:2181 \
-p 13000:3000 \
-p 14200:4200 \
-p 16080:6080 \
-p 18000:8000 \
-p 18080:8080 \
-p 18744:8744 \
-p 18886:8886 \
-p 18888:8888 \
-p 18993:8993 \
-p 19000:9000 \
-p 19090:9090 \
-p 19091:9091 \
-p 43111:42111 \
-p 62888:61888 \
-p 25000:15000 \
-p 25001:15001 \
-p 25002:15002 \
-p 25003:15003 \
-p 25004:15004 \
-p 25005:15005 \
-p 12222:22 \
-p 17000:17000 \
-p 17001:17001 \
-p 17002:17002 \
-p 17003:17003 \
-p 17004:17004 \
-p 17005:17005 \
orendain/hdf-trucking-iot /usr/sbin/sshd -D

Once the container is created, SSH into the HDF sandbox:

ssh [email protected] -p 12222 # password: greenhadoop

Execute the pre-included script:

/root/nifi-to-nifi-with-schema.sh

Open the web applicaton: http://sandbox.hortonworks.com:25001

Optionally check out the NiFi Flow and Storm UI.

Note: If you're not on the HDF Sandbox, you'll need to replace the default cluster hostname "sandbox.hortonworks.com" in the following files, as well as check the port endpoints:

trucking-schema-registrar/src/main/resources/application.conf

trucking-storm-topology/src/main/resources/application.conf

trucking-web-application/backend/conf/application.conf

/scripts/*.sh

1. On your sandbox/cluster, download this project.

git clone https://github.com/orendain/trucking-iot.git

2. Run the included automated deployment script. Read a comicbook, this may take a few minutes.

Note: By default the application deploys a Nifi -> Storm -> Nifi -> Kafka -> Web Application pipeline, with integration with Hortonworks Schema Registry.

To use a different pre-built pipeline, open/edit scripts/setup-environment.sh and scripts/builds/storm-topology.sh before running the commands below.

cd trucking-iot
scripts/auto-deploy.sh

3. On your local machine, open a browser and navigate to the web application: http://sandbox.hortonworks.com:25001

4. Optionally check out the NiFi Flow and Storm UI.

For an indepth look at the different components, check out the Trucking IoT Wiki. For any questions or requests for more documentation, feel free to open an issue or fork this repo and contribute!