internet of things (iot) - in the cloud or rather on-premises?

BASEL BERN BRUGG DÜSSELDORF FRANKFURT A.M. FREIBURG I.BR. GENF HAMBURG KOPENHAGEN LAUSANNE MÜNCHEN STUTTGART WIEN ZÜRICH

Internet of Things (IoT)in the cloud or rather on-premises?

Guido Schmutz – 5.7.2017

@gschmutz guidoschmutz.wordpress.com

Guido Schmutz

Working at Trivadis for more than 20 yearsOracle ACE Director for Fusion Middleware and SOAConsultant, Trainer Software Architect for Java, Oracle, SOA andBig Data / Fast DataHead of Trivadis Architecture BoardTechnology Manager @ Trivadis

More than 30 years of software development experience

Contact: [email protected]: http://guidoschmutz.wordpress.comSlideshare: http://www.slideshare.net/gschmutzTwitter: gschmutz

2

Agenda

3

1. IoT Architecture & Building Blocks2. IoT Reference Architecture3. Cloud IoT Solutions4. On-Premises IoT Solutions5. Hybrid IoT Solutions

Internet of Things (IoT) Wave

Internet of Things (IoT): Enabling communication between devices, people& processes to exchange useful information & knowledge that create value for humans

Term first proposed by Kevin Ashton in 1999

Source:TheEconomist Source:Ericsson,June2016

IoT Architecture & Building Blocks

5

Architecture Drivers

6

LargeScale

Security

ConstrainedDevices

LargeVolume

LegacySupport

NeedforReal-Time

Millionsofclientsinasinglenetwork.IPv6istherightwaytogo…

Sensorsexposedtotheworld,datatravelsthroughpublicnetworks…

Lossy networks,lowbandwidth,smallbatteries…

Millionsofsensorsproducetonsofdata,allthetime…

Non-IP,specializeddevices,multipleverticalsolutions

Whathappensnowmayresultinproactiveaction…

IoT World Forum Reference Model

7Source: https://www.iotwf.com/

IoT World Forum Reference Model

8Source: https://www.iotwf.com/

Sensor vs. Actuators

9

1)PhysicalDevices&Controllers

Source: cisco

Smart Objects

10

1)PhysicalDevices&Controllers

Source: cisco

Sensor Characteristics

11

ConnectedtoPowerorBatteryoperated Lowerpowerneedtotransmitlessoften,atshorterrange,simplerdata

MobileorStatic Whatistherangeandfrequencyofmobility?ImpactonpowerandGateway

LoworHighReportingFrequency Hundredoftimespersecond,oronceortwiceamonth?

SimpleorRichData Onestatusbytesorhundredsofparameters?

TransmissionRange Fewfeetorseveralmiles?

DensityperCell “afewsensors”or“severalthousands”?

1)PhysicalDevices&Controllers 2)Connectivity

Access Technologies and Distances

12

2)Connectivity

Source: cisco

Traditional IT Cloud Computing Model

13

Standard model

Endpoint like computer, notebooks, tablets … connect to a core network

communication between endpoints

data center or cloud backend where an application is running

3 layered connectivity architecture

3)EdgeComputing

Source: cisco

IT Model, with IoT Requirements

14

• Additional Fog Layer between Devices and Core Network

• supports for filter/aggregation in edge/fog layer

• supports lower latency action / reaction => direct feedback loop

3)EdgeComputing

Source: cisco

Edge vs. Mist vs. Fog Computing

15

Edge Computing

• brings compute, storage and networking resources directly to the endpoints

• compute resources inside the device, probably very constrained resources

• The edge feeds data into the Fog layer

Mist Computing

• Direct communications between edge devices

Fog Computing

• brings compute, storage and networking as close to the endpoints as possible

• away from the cloud, but does not include the endpoints

3)EdgeComputing

Streaming Analytics

17

Simple Event Processing

Event Stream Processing

Complex Event Processing

3)EdgeComputing 4)DataAccumulation 5)Application

Server-Less

18

Run code “without” servers => only specify functions

Pay only for the compute time you consume => save money

Triggered by events or called from API’s• store an object into an object/blob

storage system (S3)• updates to a NoSQL database

(trigger)• arrival of an IoT message (event)

Makes it easy to • perform real-time processing• build scalable back-end services• glue and choreograph systems

Functions can be written in various languages, such as• Java / C#• Python• Node.js

Might have higher latency (due to function being loaded at call-time)

3)EdgeComputing 4)DataAccumulation 5)DataAbstraction

Data StorageKeyValueStore

Wide-columnstore

Documentstore

Graphstore

Key ValueK1 V1K2 V2K3 V3

Document{k1:v1,k2:v2,k3:[v1,v2,v3]}

RowkeyCK1

RK1V1

CK2V2

CK3V3

CK4V4

……

CK1RK2V1

CK4V4

CK6V6

……

…………

CK3V3

Big Data und DWH Architekturworkshop19

5)DataAbstraction

Data StorageObjectStorage/KeyValueStore

Wide-columnstore

Documentstore

Graphstore

Big Data und DWH Architekturworkshop20

5)DataAbstraction

21

IoT Reference Architecture

API/ServiceIntegration

IoT Services

IoT Logical Reference Architecture

LowPowerIoT DeviceSensor

Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

22

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB

ContainerizedAppsMicroService

RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API

ExistingIoT DeviceSensor

Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP


IoT Services

IoT Logical Reference Architecture


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

23

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP

PhysicalDevices&Controllers

Connectivity

EdgeComputing DataAccumulation

DataAbstraction

Application

Collaboration&Processes

24

Cloud IoT Solutions


IoT Services

Amazon IoT Platform


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

33

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP

RulesEngine

Lambda

S3

Greengrass

S3 DynamoDB

DynamoDB

MessageBroker

ThingShadow

ThingRegistry

AWSIoT Platform EWR

Kine

sisFire

hose

SQS

EC2ContainerService

EC2ContainerRegistry

SnowmobileSnowballEdge

Snowball

Polly

ML

Lex

Recognition

Elasticsearch

KinesisAnalytics

KinesisStreams

SNS

Email

Pinp

oint

APIG

atew

ay

MobileHub

MobileSDK

Cognito

Lambda

Lambda

EC2

AutoScaling

RulesEngine

Lambda


IoT Services

Microsoft Azure Cloud


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

38

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP

IoT Edge

StreamAnalytics

DocumentDB

IoT Gateway

IoTHu

b

Even

tHubFunctions

ServiceBu

s

HDInsight

Storage

Storage

MachineLearning

DocumentDB

DataLake

BizTalkServices

Notificatio

nHu

b

PowerBI

StreamAnalytics

APIM

anagem

ent

IoT Suite


IoT Services

Oracle Cloud


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

44

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP Ev

entH

ubCS

IoT CS

StreamAnalytics

BigDataCS

StreamAnalytics NoSQLCS

BigDataDiscoveryCS

BigDataPreparationCS

EdgeAnalytics

IoT CSGateway

SOACS

ProcessCSIntegrationCS

MessagingCS MobileCS

ContainerCS

ApplicationContainerCS

BICS

DataflowM

L

NoSQL

DeviceMgmt

ServiceCS

FieldServiceCS

Oracle Cloud Demo @ Schwabengipfel

45

IOTCS

MobileCS

SOACS

IntegrationCSBICS

Process CS

DOCS

ServiceCloudOPACS

FieldServiceCloud

Oracle Cloud Demo @ SchwabengipfelArchitecture & Oracle Cloud Services used

Confidential – Oracle Internal/Restricted/Highly Restricted46

49

IoT on-premises


IoT Services

IoT on-premises – Oracle Cloud Machine


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

50

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP Ev

entH

ubCS

IoT CS

StreamAnalytics

BigDataCS

StreamAnalytics NoSQLCS

BigDataDiscoveryCS

BigDataPreparationCS

EdgeAnalytics

IoT CSGateway

SOACS

ProcessCSIntegrationCS

MessagingCS MobileCS

ContainerCS

ApplicationContainerCS

BICS

DataflowM

L

NoSQL

DeviceMgmt

ServiceCS

FieldServiceCS


IoT Services

IoT on-premises – Open Source


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

51

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP

52

Hybrid IoT Solution


IoT Services

Hybrid IoT Solutions


Actuator

IoT Gateway

UI

f()

EnterpriseApps

ProcessMgmt

RuleEngine

IoTHu

b

BigData/BI

Service

UIBL

Object

Analytics/ML

API

RESTHTTPKAFKA

MQTTAMQPHTTPBLE

ZigBeeWIFIWired

UIProvisioning

DeviceMgmt

State

MessageIntegration

Even

tHub

APIG

W/ServiceBu

s

StreamingAnalytics

RuleEngine DB

DB


RESTSOAPHTTP

IPCapableIoT Device

Sensor

Actuatorf()

DB

DB

Analytics

DB

RuleEngine

Analytics

API


Actuator

MQTTAMQPHTTP

MQTTAMQPHTTP

Cloud On-PremisesFogEdge

Guido SchmutzTechnology Manager

[email protected]

@gschmutz guidoschmutz.wordpress.com