[
https://issues.apache.org/jira/browse/IOTDB-3251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Liu reassigned IOTDB-3251:
------------------------------
Assignee: Wei Liu
> ForwardTrigger: support MQTT/HTTP data forwarding
> -------------------------------------------------
>
> Key: IOTDB-3251
> URL: https://issues.apache.org/jira/browse/IOTDB-3251
> Project: Apache IoTDB
> Issue Type: New Feature
> Components: Core/Engine
> Reporter: gongning
> Assignee: Wei Liu
> Priority: Major
> Labels: pull-request-available
>
> 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')
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
