Streamr Core

Streamr Core.
The real-time data toolkit

All the tools needed to create, process, visualise and sell your real-time data. Create a stream from your devices, filter it with our drag and drop canvas tool, visualise it on a dashboard, or create a product and sell it on our marketplace.

All the tools needed to create, process, visualise and sell your real-time data.
Create a stream from your devices, filter it with our drag and drop canvas tool,
visualise it on a dashboard, or create a product and sell it on our marketplace.

Create

Create

Create streams, canvases, dashboards and products with a simple drag & drop UI

Collaborate

Collaborate

Share, collaborate and publish your work

Integrate

Integrate

Build bridges between existing APIs and Streamr

Prototype

Prototype

Quickly build reactions to real-time data

Analytics

Analytics

Basic filtering, aggregation and rolling statistics

Build Oracles

Build Oracles

Easily build rules to interact with Ethereum smart contracts

What can you do with Core?

Create a real-time data stream

Bring your real-time data easily into Core. Our simple flow allows for quick setup of data types and fields, through auto-detect or drag and drop. Monitor all your stream statuses in Core, and easily add them to canvases, dashboards or products.

Process your streams on a canvas

Need to clean, process or visualise your streams? Core's visual editor has 150+ modules to help with that, and you don't need to know any code to do so. Run real-time or historical processes, and share your results with one click.

Visualise your data with a dashboard

Need a quick visualisation of your data? Any chart or table modules you use in canvases can be added with a click to a customisable dashboard. Combine visualisations to monitor processes or share with others.

Create and sell a data product

With Streamr's integrated Marketplace, unlocking the value of your data streams is just a few clicks away in Core. Add your streams, set up some details, publish your product and earn DATA on the Marketplace.

Chart
in1
15 minutes
15k10k5k0-5k
Wednesday, Oct 3, 06:50:20
RateLimit.out 6,088.73
Map
ID
Heading
Latitude
Longitude
Map
+
-
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.080
10007.69678933
2018-10-01 07:02:07.348
10007.10487891
2018-10-01 07:02:08.212
10007.69374808
2018-10-01 07:02:09.538
10007.96842177
2018-10-01 07:02:10.520
10007.18789957
2018-10-01 07:02:11.053
10007.18104031
2018-10-01 07:02:12.493
10008.82226860
2018-10-01 07:02:13.043
10008.62809570
2018-10-01 07:02:14.789
10007.25536243
2018-10-01 07:02:15.338
10008.23665867
2018-10-01 07:02:16.055
10008.27132540
Gradient
minValue
0
color
maxValue
1
minColor
maxColor
in
Solidity Module
ethAccount
Tram demo
contract
recipientAddress
0x9e3d69305d
unitPrice wei
10000
initial ETH
0.01
ConstantColor
Value
Color
Switcher
Out
RandomString
Length
10
Out
Trigger
Clock
Timezone
UTC
Date
Format
yyyy-MM-dd HH:mm:ss z
Timestamp
Rate
1
Unit
second
MQTT
URL
URL
Message
Topic
Topic
Username
username
Password
password
Cert Type
none
Expression
Expression
x+y
Out
X
x
Error
Y
y
RateLimit
Rate
1
Limit Exceeded
Time in Millis
1000
Out
In
Regex
Pattern
pattern
Match
Text
text
Match Count
Match List
HTTP Request
Verb
POST
Errors
URL
URL
Data
Params
Key Value
Status Code
Headers
Key Value
Roundtrip Millis
body
Headers
SQL
Engine
MySQL
Errors
Host
Host
Result
Database
database
Username
username
Password
password
Sql
sql
Note
Use Core's node based canvas editor to filter, clean, process and visualise your data. With over 150 modules to choose from, plus the ability to run your own code with the Java module, Core lets you handle data the way you choose.
Stream
Stream
Vehicle
Speed
Heading
Latitude
Longitude
Line
Search or select a module
Time Series
Text
Time & Date
Boolean
Custom Modules
Visualisations
Utils
Integrations
Input
Map
List Streams
Button
buttonName
Start
Out
buttonValue
1
Start
Note
Quickly test out ideas, clean up noisy data, and visualise almost anything in minutes.
EthereumCall
ethAccount
Tram demo
errors
function
update
spentWei
contract
targetChangeWei
addedUnits
gasUsed
gasPriceWei
blockNumber
nonce
txHash
OutOfFunds.debt
Paid.amount
Recipient.balance
Contract balance
CodeEditor
1// Define inputs and outputs here
2// TimeSeriesInput input = new TimeSeriesInput(this,"in");
3// TimeSeriesOutput output = new TimeSeriesOutput(this,"out");
4
5public void initialize() {
6 // Initialize local variables
7}
8
9public void sendOutput() {
10 // Write your module code here
11}
12
13public void clearState() {
14 // Clear internal state
15}
Scheduler
Timezone
UTC
value
Send value
0
every
day
from
00 : 00
to
00 : 00
Email
subject
Your subject here
message
Your message here
value1
Chart
in1
15 minutes
15k10k5k0-5k
Wednesday, Oct 3, 06:50:20
RateLimit.out 6,088.73
Map
ID
Heading
Latitude
Longitude
Map
+
-
Search or select a module
Time Series
Text
Time & Date
Boolean
Custom Modules
Visualisations
Utils
Integrations
Input
Map
List Streams
Note
Quickly test out ideas, clean up noisy data, and visualise almost anything in minutes.
Switcher
Out
Gradient
minValue
0
color
maxValue
1
minColor
maxColor
in
Stream
Stream
Vehicle
Speed
Heading
Latitude
Longitude
Line
Expression
Expression
x+y
Out
X
x
Error
Y
y
RateLimit
Rate
1
Limit Exceeded
Time in Millis
1000
Out
In
EthereumCall
ethAccount
Tram demo
errors
function
update
spentWei
contract
targetChangeWei
addedUnits
gasUsed
gasPriceWei
blockNumber
nonce
txHash
OutOfFunds.debt
Paid.amount
Recipient.balance
Contract balance
Note
Use Core's node based canvas editor to filter, clean, process and visualise your data. With over 150 modules to choose from, plus the ability to run your own code with the Java module, Core lets you handle data the way you choose.
Regex
Pattern
pattern
Match
Text
text
Match Count
Match List
Button
buttonName
Start
Out
buttonValue
1
Start
Scheduler
Timezone
UTC
value
Send value
0
every
day
from
00 : 00
to
00 : 00
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.173
10008.24407819
2018-10-01 07:02:07.884
10007.69556187
2018-10-01 07:02:08.164
10008.56382247
2018-10-01 07:02:09.019
10007.43941719
2018-10-01 07:02:10.823
10008.05122201
2018-10-01 07:02:11.519
10007.15096856
2018-10-01 07:02:12.050
10007.48794547
2018-10-01 07:02:13.124
10007.54580793
2018-10-01 07:02:14.942
10007.63824907
2018-10-01 07:02:15.934
10007.26124584
2018-10-01 07:02:16.113
10007.03450535
Solidity Module
ethAccount
Tram demo
contract
recipientAddress
0x9e3d69305d
unitPrice wei
10000
initial ETH
0.01
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.384
10007.17171555
2018-10-01 07:02:07.598
10007.33968294
2018-10-01 07:02:08.861
10008.24829502
2018-10-01 07:02:09.842
10007.58715256
2018-10-01 07:02:10.422
10007.40857505
2018-10-01 07:02:11.792
10007.84741588
2018-10-01 07:02:12.649
10008.95456535
2018-10-01 07:02:13.735
10008.41727879
2018-10-01 07:02:14.014
10008.15985663
2018-10-01 07:02:15.884
10008.28750906
2018-10-01 07:02:16.390
10008.36103751
Clock
Timezone
UTC
Date
Format
yyyy-MM-dd HH:mm:ss z
Timestamp
Rate
1
Unit
second
MQTT
URL
URL
Message
Topic
Topic
Username
username
Password
password
Cert Type
none
Some of our partners
GSMAHewlett Packard EnterpriseLYNKEUS
UnionBankWorld Wide Fund for NatureAtoS
IICMPTCGDST
GSMAHewlett Packard EnterpriseLYNKEUSUnionBank
World Wide Fund for NatureAtoSIICMPTCGDST