
Processing
AES-GCM Decryptor
This module decrypts data encrypted with AES-GCM
GitHub
Output
AWS DynamoDB Egress
Responsible for saving data into the AWS DynamoDB.
GitHubProcessing
Aggregator
Apply aggregation functions to your data.
GitHub
Output
Airtable
Write data to a selected Airtable base.
GitHubProcessing
Bandstop Filter
Module that filters out frequencies
GitHub
Processing
Batcher
Data collection and batching.
GitHubOutput
CSV Export
Module collects incoming data and stores it to CSV files splitted by its size or number of rows.
GitHub
Output
CassandraDB
Use REST API to write data to your Apache CassandraDB
GitHubProcessing
Comparison Filter
Filtering data according to query
GitHubInput
DHT sensor simulator
This is a module to simulate a data input from a temperature and humidity sensor.
GitHubProcessing
Data Converter
This module allows user to convert input data from and to [int,ieee754 float,string text,string hex] and forward the new data to next module .
GitHubProcessing
Data Flattener
Flatten your nested data.
GitHubProcessing
Data Plotter
Receive and plot data, then send the graph file to the next module.
GitHubProcessing
Data Unflattener
Restore your flattened data to its previous nested form.
GitHubOutput
Discord
Send messages and alerts to a selected Discord channel.
GitHubOutput
DolphinDB
Write data to your DolphinDB.
GitHubProcessing
Encryption At Rest
Data Encryption and Entropy Calculation
GitHubProcessing
Fast Fourier Transform
Get elementary frequencies and magnitudes of your data.
GitHubProcessing
Fields Renamer
Rename fields (labels) in your data.
GitHubProcessing
Fields Selector
Select data fields (labels) to keep or remove.
GitHubProcessing
Fluctuation Filter
Providing stable data by filtering out spikes.
GitHubOutput
GMail
Send data with your GMail.
GitHubOutput
Google Chat
Send messages and alerts to a selected Google Chat.
GitHubOutput
Google Sheets
Write data to a selected Google Sheet. All credentials should be provided from the JSON file generated in Google Cloud Console.
GitHubInput
HTTP Client Requests
This Module performs repeated HTTP requests at a specified interval, to the given URL.
GitHubOutput
HTTP Egress
Send your data to a third party via HTTP.
GitHubInput
HTTP Ingress
Data ingress for HTTP ReST API requests.
GitHubInput
I2C Input
This module allows users to read data from a single I2C slave register and forward it to the next module.
GitHubOutput
InfluxDB
Write data to a selected InfluxDB bucket.
GitHubProcessing
InfluxDB Query
The module sends query to InfluxDB and reads data.
GitHubProcessing
Innotas Water Sensor Decoder
Decoder for Innotas Water Sensor data.
GitHubProcessing
JSON Stringify
Accepts an arbitrary JSON object, and returns the stringified version.
GitHubOutput
Jira Service Management
Generate Service Requests in Jira Service Management.
GitHubInput
Kafka Consumer
Consumer to connect with Apache Kafka.
GitHubOutput
Kafka Producer
Producer to connect with Apache Kafka.
GitHubOutput
MQTT Egress
Send data to a remote MQTT broker.
GitHubInput
MQTT Ingress
Data ingress for MQTT.
GitHubInput
MQTT Ingress
MQTT Ingress is an ingress module responsible for getting data into the data service. It subscribe to a MQTT Broker on a topic.
GitHubProcessing
Math Operations
This module enables performing math operations on the data. Supported operations: + - * / % ^ ceil abs floor sqrt sin cos tan exp
GitHubProcessing
McClimate Vicki Decoder
Decoder for McClimate Vicki Decoder.
GitHubProcessing
McClimate Vicki Encoder
Encoder for McClimate Vicki Encoder
GitHubOutput
Melita IO Batch
Module for communication with melita.io API for devices controller, for sending requests to multiple devices.
GitHubOutput
Melita IO Egress
Module for communication with Melita.io API for devices controller.
GitHubProcessing
Melita Profile Filter
Module filters Melita payloads by profile IDs and matched payloads forwards to new endpoint while others forwards to regular next EGRESS module in pipeline.
GitHubProcessing
Message Composer
Compose a customized message. Use double curly brackets (i.e. {{temperature}}) to emplace data assigned to given label within the message.
GitHubProcessing
Milesight Decoder
Decoder for Milesight Data.
GitHubProcessing
Modbus Payload Converter
This module is receiving the register response of a Modbus (or similar protocol) module and converts to a human readable format.
GitHub
Input
ModbusTCP Ingress
Module ingressing data from ModbusTCP server.
GitHubOutput
MongoDB
Write data to a selected MongoDB database and collection.
GitHubInput
OPC UA Discovery
OPC UA Discovery looks for all available nodes onn OPC UA Server and forwards the payload to next module.
GitHubInput
OPC UA Reader
OPC UA Reader reads values for variables and forwards the payload to next module.
GitHubInput
OPC UA Subscribe
OPC UA Subscribe connects to OPC UA Server and listens for incoming data messages and forwards the payload to next module.
GitHubProcessing
Outlier Detector
Outlier detection and removal. The following parameters can be (optionally) specified to filter the outliers out.
GitHubInput
PostgreSQL Query
Periodically poll data from a PostgreSQL DB.
GitHub
Input
Prinect Ingress
Data ingress for Prinect API requests.
GitHubProcessing
PyTorch CPU
Use your PyTorch model with CPU device settings.
GitHubOutput
QuestDB
Use REST API to insert data into your QuestDB table.
GitHubInput
Random Hash Generator
Ingress module generating a random hash string by reading from /dev/random and hashing the bytes.
GitHubOutput
SAP HANA Database Egress
Store your Data in your SAP HANA HDBSQL Database.
GitHubProcessing
Scikit Learn
Use your scikit-learn model.
GitHubOutput
SeaTable
Write data to a selected SeaTable base. Make sure that column names in SeaTable match data labels.
GitHubProcessing
Serial Data Decryptor
Weeve module that decrypts the cyphertext received from the previous module using AES-GCM algorithm and forwards the plaintext to the next module.
GitHubInput
Serial Input
This module allows users to read serial data and send it to next module.
GitHubProcessing
Signal Timer
Monitors the input and starts a counter measuring the duration that the signal keeps or exceeds a certain value.
GitHubOutput
Slack Alert
Sending alerts and notifications to Slack Channels
GitHubProcessing
Spy
Debugging module disclosing in logs all data passing through it.
GitHubOutput
Telegram
Send an alert or a notification to your Telegram.
GitHubOutput
TimescaleDB
Insert data into your TimescaleDB
GitHubProcessing
Timestamp
Add timestamp to your data.
GitHubInput
Vibrations Simulator
Simulate vibrations waveform data.
GitHubOutput
Vonage
Send alerts and notifications to your WhatsApp, Facebook Messenger and SMS channels.
GitHubInput
Websocket Ingress
The module should connect to Websocket endpoint and listen for incoming messages. Then forward the payload to next module in weeve appropriate JSON format.
GitHubProcessing
hash-to-int
Return the integer representation of a byte string sha256.
GitHub