Process Your MQTT Data in Real-time
Efficiently extract, filter, enrich, and transform your IoT data in real-time utilizing the SQL-based rule engine or stream processing engine. Accelerate IoT application integration and business innovation.
Capabilities
SQL-based Real-time Data Processing
Real-time processing of data streams using SQL. Filter, transform, and analyze data on-the-fly to gain insights.
'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M12.0234%2026.625H13.8828L16.9922%2035.1875L20.0938%2026.625H21.9609L17.7344%2038H16.2422L12.0234%2026.625ZM11.0859%2026.625H12.9062L13.2344%2034.4922V38H11.0859V26.625ZM21.0703%2026.625H22.8984V38H20.75V34.4922L21.0703%2026.625ZM31.1875%2036.3984L34.2188%2038.8047L32.8438%2040L29.8594%2037.6094L31.1875%2036.3984ZM34.2734%2032.0234V32.6094C34.2734%2033.4688%2034.1589%2034.2422%2033.9297%2034.9297C33.7005%2035.612%2033.3724%2036.1927%2032.9453%2036.6719C32.5234%2037.151%2032.0208%2037.5182%2031.4375%2037.7734C30.8542%2038.0286%2030.2083%2038.1562%2029.5%2038.1562C28.7969%2038.1562%2028.151%2038.0286%2027.5625%2037.7734C26.9792%2037.5182%2026.474%2037.151%2026.0469%2036.6719C25.6198%2036.1927%2025.2891%2035.612%2025.0547%2034.9297C24.8203%2034.2422%2024.7031%2033.4688%2024.7031%2032.6094V32.0234C24.7031%2031.1589%2024.8177%2030.3854%2025.0469%2029.7031C25.2812%2029.0208%2025.6094%2028.4401%2026.0312%2027.9609C26.4583%2027.4766%2026.9635%2027.1068%2027.5469%2026.8516C28.1354%2026.5964%2028.7812%2026.4688%2029.4844%2026.4688C30.1927%2026.4688%2030.8385%2026.5964%2031.4219%2026.8516C32.0104%2027.1068%2032.5156%2027.4766%2032.9375%2027.9609C33.3646%2028.4401%2033.6927%2029.0208%2033.9219%2029.7031C34.1562%2030.3854%2034.2734%2031.1589%2034.2734%2032.0234ZM32.1016%2032.6094V32.0078C32.1016%2031.388%2032.0443%2030.8438%2031.9297%2030.375C31.8151%2029.901%2031.6432%2029.5026%2031.4141%2029.1797C31.1901%2028.8568%2030.9167%2028.6146%2030.5938%2028.4531C30.2708%2028.2865%2029.901%2028.2031%2029.4844%2028.2031C29.0729%2028.2031%2028.7057%2028.2865%2028.3828%2028.4531C28.0599%2028.6146%2027.7865%2028.8568%2027.5625%2029.1797C27.3385%2029.5026%2027.1667%2029.901%2027.0469%2030.375C26.9323%2030.8438%2026.875%2031.388%2026.875%2032.0078V32.6094C26.875%2033.224%2026.9323%2033.7682%2027.0469%2034.2422C27.1667%2034.7161%2027.3385%2035.1172%2027.5625%2035.4453C27.7917%2035.7682%2028.0677%2036.013%2028.3906%2036.1797C28.7188%2036.3464%2029.0885%2036.4297%2029.5%2036.4297C29.9167%2036.4297%2030.2865%2036.3464%2030.6094%2036.1797C30.9323%2036.013%2031.2031%2035.7682%2031.4219%2035.4453C31.6458%2035.1172%2031.8151%2034.7161%2031.9297%2034.2422C32.0443%2033.7682%2032.1016%2033.224%2032.1016%2032.6094ZM40.7031%2026.625V38H38.5625V26.625H40.7031ZM44.2344%2026.625V28.3203H35.0703V26.625H44.2344ZM50.6719%2026.625V38H48.5312V26.625H50.6719ZM54.2031%2026.625V28.3203H45.0391V26.625H54.2031Z'%20fill='url(%23paint1_linear_6073_9025)'/%3e%3cpath%20d='M12%2012H52'%20stroke='url(%23paint2_linear_6073_9025)'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M12%2052H52'%20stroke='url(%23paint3_linear_6073_9025)'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M21%2060H43'%20stroke='url(%23paint4_linear_6073_9025)'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M21%204H43'%20stroke='url(%23paint5_linear_6073_9025)'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cdefs%3e%3clinearGradient%20id='paint0_linear_6073_9025'%20x1='5.90909'%20y1='25.8235'%20x2='31.584'%20y2='59.6259'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint1_linear_6073_9025'%20x1='11.5341'%20y1='28.1471'%20x2='31.5813'%20y2='55.1401'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint2_linear_6073_9025'%20x1='13.3636'%20y1='12.2794'%20x2='13.4358'%20y2='14.1804'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint3_linear_6073_9025'%20x1='13.3636'%20y1='52.2794'%20x2='13.4358'%20y2='54.1804'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint4_linear_6073_9025'%20x1='21.75'%20y1='60.2794'%20x2='21.8808'%20y2='62.1741'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint5_linear_6073_9025'%20x1='21.75'%20y1='4.27941'%20x2='21.8808'%20y2='6.17409'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3c/defs%3e%3c/svg%3e)
Event Triggers for MQTT Client
The rule engine can respond to events such as client connected/disconnected, topic subscribe/unsubscribe, and message publish/deliver.
'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M18%2055H47'%20stroke='url(%23paint1_linear_6073_9024)'%20stroke-width='2'%20stroke-linecap='round'%20stroke-linejoin='round'/%3e%3cpath%20d='M27.2734%2038H24.4492V24.1016C24.4492%2023.1562%2024.625%2022.3633%2024.9766%2021.7227C25.3359%2021.0742%2025.8477%2020.5859%2026.5117%2020.2578C27.1758%2019.9219%2027.9609%2019.7539%2028.8672%2019.7539C29.1484%2019.7539%2029.4258%2019.7734%2029.6992%2019.8125C29.9727%2019.8438%2030.2383%2019.8945%2030.4961%2019.9648L30.4258%2022.1445C30.2695%2022.1055%2030.0977%2022.0781%2029.9102%2022.0625C29.7305%2022.0469%2029.5352%2022.0391%2029.3242%2022.0391C28.8945%2022.0391%2028.5234%2022.1211%2028.2109%2022.2852C27.9062%2022.4414%2027.6719%2022.6719%2027.5078%2022.9766C27.3516%2023.2812%2027.2734%2023.6562%2027.2734%2024.1016V38ZM29.8867%2025.3203V27.3828H22.5039V25.3203H29.8867ZM34.0938%2025.3203L36.5078%2029.5273L38.9688%2025.3203H42.0742L38.2305%2031.543L42.2266%2038H39.1211L36.543%2033.6172L33.9648%2038H30.8477L34.832%2031.543L31%2025.3203H34.0938Z'%20fill='url(%23paint2_linear_6073_9024)'/%3e%3cdefs%3e%3clinearGradient%20id='paint0_linear_6073_9024'%20x1='5.90909'%20y1='20.8971'%20x2='42.9726'%20y2='55.9302'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint1_linear_6073_9024'%20x1='18.9886'%20y1='55.2794'%20x2='19.0881'%20y2='57.1779'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint2_linear_6073_9024'%20x1='22.7159'%20y1='23.8235'%20x2='43.875'%20y2='34.2699'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3c/defs%3e%3c/svg%3e)
Rich built-in Functions
A bunch of predefined operations can be used within the Rule Engine to process and manipulate the data streams more effectively and efficiently.
'%20stroke-width='2'%20stroke-linecap='round'/%3e%3cpath%20d='M20%2050H41'%20stroke='url(%23paint1_linear_6073_9023)'%20stroke-width='2'%20stroke-linecap='round'%20stroke-linejoin='round'/%3e%3cpath%20d='M20%2042H46'%20stroke='url(%23paint2_linear_6073_9023)'%20stroke-width='2'%20stroke-linecap='round'%20stroke-linejoin='round'/%3e%3cpath%20d='M20%2034H46'%20stroke='url(%23paint3_linear_6073_9023)'%20stroke-width='2'%20stroke-linecap='round'%20stroke-linejoin='round'/%3e%3cpath%20d='M22.3115%2020.2783L28.0068%2022.4053V24.6377L20.5098%2021.3945V19.8652L22.3115%2020.2783ZM28.0068%2018.5469L22.3115%2020.709L20.5098%2021.0957V19.5576L28.0068%2016.3232V18.5469ZM35.7236%2013.2031L30.8896%2027.0986H29.123L33.957%2013.2031H35.7236ZM42.8867%2020.6299L37.1035%2018.5293V16.3145L44.7324%2019.5576V21.1045L42.8867%2020.6299ZM37.1035%2022.4316L42.8955%2020.2695L44.7324%2019.8564V21.3945L37.1035%2024.6377V22.4316Z'%20fill='url(%23paint4_linear_6073_9023)'/%3e%3cdefs%3e%3clinearGradient%20id='paint0_linear_6073_9023'%20x1='10.6023'%20y1='20.8088'%20x2='54.5315'%20y2='46.4527'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint1_linear_6073_9023'%20x1='20.7159'%20y1='50.2794'%20x2='20.8529'%20y2='52.1732'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint2_linear_6073_9023'%20x1='20.8864'%20y1='42.2794'%20x2='20.9972'%20y2='44.1766'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint3_linear_6073_9023'%20x1='20.8864'%20y1='34.2794'%20x2='20.9972'%20y2='36.1766'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3clinearGradient%20id='paint4_linear_6073_9023'%20x1='20.8864'%20y1='14.8676'%20x2='40.4643'%20y2='30.8239'%20gradientUnits='userSpaceOnUse'%3e%3cstop%20stop-color='%235E4EFF'/%3e%3cstop%20offset='1'%20stop-color='%239A6AFF'/%3e%3c/linearGradient%3e%3c/defs%3e%3c/svg%3e)
Schema Registry and Message Codec
High-performance encode/decode MQTT messages in JSON, Avro, and Protobuf formats via built-in schema registry.
HTTP/gRPC Extension
Extend processing capabilities with a cross-platform HTTP/gRPC method to achieve custom types of data processing.
Complex JSON Processing
Integrate the JSON-specific processing tool jq to convert and process complex JSON data effortlessly.
Benefits
Simplified Data Processing
Effortlessly filter, transform, and distribute data using SQL-like syntax and stream processing capabilities, eliminating the need for custom code or additional tools.
Real-time Insights and Actions
The Rule Engine facilitates real-time insights by triggering actions based on specific conditions, empowering users to take prompt and informed actions.
Reduced Development Effort
The Rule Engine simplifies the development of IoT applications by providing a wide range of built-in capabilities, reducing the need to develop custom code and minimizing maintenance efforts.
Scalability and Reliability
Designed to handle high throughput and large numbers of connected devices, allowing users to scale their IoT solutions without sacrificing performance or reliability.
'%3e%3cpath%20fill-rule='evenodd'%20clip-rule='evenodd'%20d='M35.7681%2034.8789C41.8072%2034.8789%2046.7206%2029.9655%2046.7206%2023.9264C46.7206%2017.8869%2041.8072%2012.9739%2035.7681%2012.9739C35.1207%2012.9739%2034.5957%2013.4984%2034.5957%2014.1462C34.5957%2014.7937%2035.1207%2015.3186%2035.7681%2015.3186C40.5141%2015.3186%2044.3759%2019.18%2044.3759%2023.9264C44.3759%2028.6724%2040.5141%2032.5342%2035.7681%2032.5342C35.1207%2032.5342%2034.5957%2033.0592%2034.5957%2033.7066C34.5957%2034.354%2035.1207%2034.8789%2035.7681%2034.8789Z'%20fill='%2300B173'/%3e%3c/g%3e%3cpath%20fill-rule='evenodd'%20clip-rule='evenodd'%20d='M13.5648%2034.8789C14.2123%2034.8789%2014.7372%2034.354%2014.7372%2033.7066C14.7372%2033.0592%2014.2123%2032.5342%2013.5648%2032.5342C8.81884%2032.5342%204.95704%2028.6724%204.95704%2023.9264C4.95704%2019.18%208.81884%2015.3186%2013.5648%2015.3186C14.2123%2015.3186%2014.7372%2014.7937%2014.7372%2014.1462C14.7372%2013.4984%2014.2123%2012.9739%2013.5648%2012.9739C7.52572%2012.9739%202.6123%2017.8869%202.6123%2023.9264C2.6123%2029.9655%207.52572%2034.8789%2013.5648%2034.8789Z'%20fill='%2300B173'/%3e%3cpath%20fill-rule='evenodd'%20clip-rule='evenodd'%20d='M20.5444%2038.7714C28.73%2038.7714%2035.3896%2032.1118%2035.3896%2023.9262C35.3896%2015.7406%2028.73%209.08105%2020.5444%209.08105C19.897%209.08105%2019.3721%209.60558%2019.3721%2010.253C19.3721%2010.9008%2019.897%2011.4258%2020.5444%2011.4258C27.4374%2011.4258%2033.0449%2017.0333%2033.0449%2023.9262C33.0449%2030.8187%2027.4374%2036.4266%2020.5444%2036.4266C19.897%2036.4266%2019.3721%2036.9516%2019.3721%2037.599C19.3721%2038.2464%2019.897%2038.7714%2020.5444%2038.7714Z'%20fill='%2300B173'/%3e%3c/svg%3e){kind=small}
'%3e%3cpath%20fill-rule='evenodd'%20clip-rule='evenodd'%20d='M24.3327%207.07146C24.1388%207.07146%2023.9452%207.12123%2023.7719%207.22103L10.5603%2014.8492C10.2143%2015.0485%209.99958%2015.4204%209.99958%2015.8196V31.0759C9.99958%2031.4749%2010.2143%2031.8467%2010.5601%2032.0461L23.7724%2039.6745C24.1177%2039.8741%2024.5471%2039.8738%2024.8935%2039.6742L38.105%2032.0463C38.4511%2031.8467%2038.6658%2031.4749%2038.6658%2031.0759V15.8196C38.6658%2015.4204%2038.4511%2015.0485%2038.1053%2014.8492L24.8929%207.22103C24.7202%207.12097%2024.5266%207.07146%2024.3327%207.07146ZM24.3327%2042.3548C23.7013%2042.3548%2023.0694%2042.1925%2022.5063%2041.8675L9.29391%2034.2391C8.16769%2033.589%207.46777%2032.3767%207.46777%2031.0759V15.8196C7.46777%2014.5185%208.16769%2013.3066%209.29443%2012.6562L22.506%205.02826C23.6328%204.37786%2025.0331%204.37812%2026.1591%205.028L39.3714%2012.6564C40.4976%2013.3066%2041.1976%2014.5185%2041.1976%2015.8196V31.0759C41.1976%2032.3767%2040.4976%2033.589%2039.3709%2034.2394L26.1593%2041.8673C25.5959%2042.1925%2024.964%2042.3548%2024.3327%2042.3548Z'%20fill='%235E4EFF'/%3e%3c/g%3e%3c/svg%3e){kind=small}