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
06:4606:4806:5006:5206:5406:5606:5807:00
06:00
06:30
07:00
07:30
Map
ID
Heading
Latitude
Longitude
Map
+
-
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.457
10008.08752395
2018-10-01 07:02:07.336
10008.75226404
2018-10-01 07:02:08.861
10008.22940437
2018-10-01 07:02:09.236
10008.82779674
2018-10-01 07:02:10.813
10008.99122004
2018-10-01 07:02:11.124
10008.93142602
2018-10-01 07:02:12.008
10007.63727515
2018-10-01 07:02:13.586
10008.78735504
2018-10-01 07:02:14.764
10007.33395843
2018-10-01 07:02:15.776
10008.33637072
2018-10-01 07:02:16.723
10008.60753267
Gradient
minValue
0
color
maxValue
1
minColor
maxColor
in
Solidity Module
ethAccount
Tram demo
contract
recipientAddress
0x9e3d69305d
unitPrice wei
10000
initial ETH
0.01
0xaca0cc3a6bf9552f2866ccc670cc3c70aca
Edit code
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}
Show Debug
Apply
Close
Scheduler
Timezone
UTC
value
Send value
0
every
day
from
00 : 00
to
00 : 00
+ Add
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
06:4606:4806:5006:5206:5406:5606:5807:00
06:00
06:30
07:00
07:30
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.
Email
subject
Your subject here
message
Your message here
value1
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
+ Add
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.562
10007.81370883
2018-10-01 07:02:07.408
10008.97577571
2018-10-01 07:02:08.909
10007.25377218
2018-10-01 07:02:09.165
10008.16146837
2018-10-01 07:02:10.699
10007.20009683
2018-10-01 07:02:11.974
10008.06713969
2018-10-01 07:02:12.904
10008.21278649
2018-10-01 07:02:13.300
10008.47857476
2018-10-01 07:02:14.242
10008.60748558
2018-10-01 07:02:15.448
10008.61834447
2018-10-01 07:02:16.156
10008.55075608
Solidity Module
ethAccount
Tram demo
contract
recipientAddress
0x9e3d69305d
unitPrice wei
10000
initial ETH
0.01
0xaca0cc3a6bf9552f2866ccc670cc3c70aca
Edit code
Table
batch
in4+
timestamp
batch
2018-10-01 07:02:06.273
10008.75162444
2018-10-01 07:02:07.458
10008.92709052
2018-10-01 07:02:08.032
10007.26774074
2018-10-01 07:02:09.085
10008.44742828
2018-10-01 07:02:10.584
10007.09129523
2018-10-01 07:02:11.831
10008.86360577
2018-10-01 07:02:12.647
10008.21737983
2018-10-01 07:02:13.801
10007.88141531
2018-10-01 07:02:14.927
10008.20373198
2018-10-01 07:02:15.045
10008.88713563
2018-10-01 07:02:16.178
10007.56290724
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
AtarcaHewlett Packard EnterpriseLYNKEUS
UnionBankWorld Wide Fund for NatureAtoS
IICMPTCGDST
AtarcaHewlett Packard EnterpriseLYNKEUSUnionBank
World Wide Fund for NatureAtoSIICMPTCGDST