2b2e84b83c
This fixes a bug in the protobuf schema registry functionality. Before this fix one would get a badarith error if one tried to assign a float value to an uint64 field. However, this commit fixes this by upgrading gpb so we instead will get a gpb_type_error which is what we want. Fixes: https://emqx.atlassian.net/browse/EMQX-10775 |
||
|---|---|---|
| .. | ||
| etc | ||
| include | ||
| priv | ||
| src | ||
| test | ||
| BSL.txt | ||
| README.md | ||
| rebar.config | ||
EMQX Schema Registry
EMQX Schema Registry for managing various of schemas for decoding/encoding messages.
To use schema in rule engine, a schema name should be passed to the SQL functions that decode/encode data, like:
SELECT
schema_decode('sensor_notify', payload) as payload
FROM
"message.publish"
WHERE
topic = 't/1'
Using schema registry with rule engine
+---------------------------+
| |
Events/Msgs | | Events/Msgs
--------------------> EMQX |------------------>
| |
| |
+-------------|-------------+
|
HOOK |
|
+-------------v-------------+ +----------+
| | Data | |
| Rule Engine ------------- Backends |
| | | |
+------|-------------|------+ +----------+
|^ |^
Decode|| ||Encode
|| ||
+------v|------------v|-----+
| |
| Schema Registry |
| |
+---------------------------+
Architecture
| |
Decode | [APIs] | Encode
| |
| | [Registry]
+------v--------------v------+
REGISTER SCHEMA | |
INSTANCE | | +--------+
-------------------> | | |
[Management APIs] | Schema Registry ------ Schema |
| | | |
| | +--------+
| |
+----------------------------+
/ | \
+---/---+ +---|----+ +---\---+
| | | | | |
[Decoders] | Avro | |ProtoBuf| |Others |
| | | | | |
+-------+ +--------+ +-------+
- Register schema instance: adds a new instance of a schema of a certain type. For example, when the user may have several Avro or Protobuf schemas that they wish to use with different data flows.
Documentation
-
Refer to Introduction to Schema Registry for how to use the EMQX dashboard for configuring schemas.
-
Refer to EMQX Rules for the EMQX rules engine introduction.
Contributing
Please see our contributing.md.
License
EMQ Business Source License 1.1, refer to LICENSE.