Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Done
-
None
Description
For the ultimate advanced subscription capability, the specific goals of ForwardTrigger are as follows
- Upgrade Trigger and its Sink utility class
- The full path parameter can be obtained at each trigger to support prefix path subscription
- Added interfaces for batch Event processing to lay a foundation for asynchronous batch Event processing
- implement ForwardTrigger
- Implements asynchronous batch forwarding based on blocking queues
- Supports HTTP and MQTT communication protocols
- Supports connection pooling management
eg：
– http
create trigger trigger_forward_http_before before insert on root.vehicle.a.b.c.d1.s1
as 'org.apache.iotdb.db.engine.trigger.builtin.ForwardTrigger'
with ('protocol' = 'http', 'endpoint' = 'http://127.0.0.1:8080/')
– mqtt
create trigger trigger_forward_mqtt_before before insert on root.vehicle.a.b.c.d1.s3
as 'org.apache.iotdb.db.engine.trigger.builtin.ForwardTrigger'
with ('protocol' = 'mqtt', 'host' = '127.0.0.1', 'port' = '1884', 'username' = 'root', 'password' = 'root', 'topic' = 'mqtt-test')