Streamr Core

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?

Stream
Editor
Dashboard
Userpages

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.197
10008.38268341
2018-10-01 07:02:07.868
10008.85431832
2018-10-01 07:02:08.593
10008.61160139
2018-10-01 07:02:09.570
10008.89469902
2018-10-01 07:02:10.709
10008.86882214
2018-10-01 07:02:11.719
10008.24008769
2018-10-01 07:02:12.874
10007.74097398
2018-10-01 07:02:13.155
10007.60549295
2018-10-01 07:02:14.804
10008.14910199
2018-10-01 07:02:15.204
10008.19566702
2018-10-01 07:02:16.054
10008.20156137
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.674
10008.02088277
2018-10-01 07:02:07.619
10007.83542667
2018-10-01 07:02:08.091
10008.81062692
2018-10-01 07:02:09.372
10008.89390385
2018-10-01 07:02:10.931
10007.21716836
2018-10-01 07:02:11.057
10008.10298101
2018-10-01 07:02:12.299
10008.29814431
2018-10-01 07:02:13.233
10007.60245900
2018-10-01 07:02:14.640
10008.74954736
2018-10-01 07:02:15.007
10007.96587626
2018-10-01 07:02:16.670
10008.64502773
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.821
10008.41416017
2018-10-01 07:02:07.119
10007.46686028
2018-10-01 07:02:08.753
10008.26351390
2018-10-01 07:02:09.267
10007.26597369
2018-10-01 07:02:10.936
10007.37831249
2018-10-01 07:02:11.425
10008.03792466
2018-10-01 07:02:12.118
10007.37915746
2018-10-01 07:02:13.656
10008.56715615
2018-10-01 07:02:14.965
10008.32230317
2018-10-01 07:02:15.264
10007.67883056
2018-10-01 07:02:16.585
10008.71104755
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
Launched 2017
  • Basic building and running of Canvases
  • Modules for stream processing, visualizations, integrations
  • Extending functionality with inline Java
  • Basic Ethereum smart contracts interactions and deployment
2018
  • Integration to Marketplace
  • Cluster operation
  • Stability improvements
  • Scalability improvements
Q2 2019
  • Editor becomes a key part of the new Streamr Core app
  • Frontend rewrite in React/Redux
  • Improved UI & UX
  • Undo, Redo, autosave
Q4 2019
  • Ethereum mainnet support
  • Support for new Corea P2P Network
  • Support for cryptographically signed streams
  • Support for end-to-end encryption
2020
  • Require DATA to run canvases
  • Move resource metadata and permissions on-chain
  • Decouple Engine nodes from Core backend
2021
  • Decentralization of Engine nodes
  • Users can earn DATA by running Engine nodes
Some of our partners
TIoTAHewlett Packard EnterpriseDXCFastemsMOBIVTTElectrifyFysicalGolem
Ruuvi (xs)
TIoTAHewlett Packard EnterpriseMOBIFastemsDXC
VTTElectrifyGolemFysicalRuuvi
TIoTAHewlett Packard EnterpriseMOBIFastems
FysicalVTTElectrifyGolemRuuviDXC