feat:add runtime demo.
diff --git a/adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql b/adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql index 1d8a643..d9f0df9 100644 --- a/adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql +++ b/adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql
@@ -17,4 +17,24 @@ INSERT INTO `event_target_class` (`name`,`api_params`,`target_transform`,`required_params`,`visual_config`,`description`,`gmt_create`,`gmt_modify`) VALUES -('acs.dingtalk','{\n \"WebHook\":{\n \"type\":\"String\",\n \"desc\":\"the endpoint of webhook.\",\n \"required\":true\n },\n \"SecretKey\":{\n \"type\":\"String\",\n \"desc\":\"the secret key.\",\n \"required\":true\n },\n \"Body\":{\n \"type\":\"boolean\",\n \"desc\":\"the content of request\"\n }\n}','{ \"data\":\"${Body}\" }','{\n \"webHook\":\"${WebHook}\",\n \"secretKey\":\"${SecretKey}\",\n \"class\":\"org.apache.rocketmq.connect.dingtalk.sink.DingTalkSinkConnector\"\n}',NULL,'aliyun dingtalk connector config',now(),now()); \ No newline at end of file +('acs.dingtalk','{ + "WebHook":{ + "type":"String", + "desc":"the endpoint of webhook.", + "required":true + }, + "SecretKey":{ + "type":"String", + "desc":"the secret key.", + "required":true + }, + "Body":{ + "type":"boolean", + "desc":"the content of request" + } + }','{"data":"${Body}" }' + ,'{ + "webHook":"${WebHook}", + "secretKey":"${SecretKey}", + "class":"org.apache.rocketmq.connect.dingtalk.sink.DingTalkSinkConnector" + }',NULL,'aliyun dingtalk connector config',now(),now()); \ No newline at end of file
diff --git a/adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql b/adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql index b7587a0..fd24d5d 100644 --- a/adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql +++ b/adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql
@@ -17,4 +17,43 @@ INSERT INTO `event_target_class` (`name`,`api_params`,`target_transform`,`required_params`,`visual_config`,`description`,`gmt_create`,`gmt_modify`) VALUES -('acs.eventbridge','{\n \"RegionId\":{\n \"type\":\"String\",\n \"desc\":\"the region of aliyun eventbridge.\",\n \"required\":true\n },\n \"AliyunAccountId\":{\n \"type\":\"String\",\n \"desc\":\"the account id of aliyun eventbridge.\",\n \"required\":true\n },\n \"AliyunEventBus\":{\n \"type\":\"String\",\n \"desc\":\"the bus of aliyun eventbridge.\",\n \"required\":true\n },\n \"AccessKeyId\":{\n \"type\":\"String\",\n \"desc\":\"the accessKeyId of aliyun eventbridge.\",\n \"required\":true\n },\n \"AccessKeySecret\":{\n \"type\":\"String\",\n \"desc\":\"the accessKeySecret of aliyun eventbridge.\",\n \"required\":true\n }\n}','{\n \"data\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$.data\\\"}\",\n \"id\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$.id\\\"}\",\n \"type\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$.type\\\"}\",\n \"specversion\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$. specversion\\\"}\",\n \"subject\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$.subject\\\"}\",\n \"source\":\"{\\\"form\\\":\\\"JSONPATH\\\",\\\"value\\\":\\\"$.source\\\"}\"\n}','{\n \"aliyuneventbusname\":\"${AliyunEventBus}\",\n \"accessKeyId\":\"${AccessKeyId}\",\n \"accessKeySecret\":\"${AccessKeySecret}\",\n \"accountEndpoint\":\"${AliyunAccountId}.eventbridge.${RegionId}.aliyuncs.com\",\n \"class\":\"org.apache.rocketmq.connect.eventbridge.sink.EventBridgeSinkConnector\"\n}',NULL,'aliyun eventbridge connector config',now(),now()); +('acs.eventbridge','{ + "RegionId":{ + "type":"String", + "desc":"the region of aliyun eventbridge.", + "required":true + }, + "AliyunAccountId":{ + "type":"String", + "desc":"the account id of aliyun eventbridge.", + "required":true + }, + "AliyunEventBus":{ + "type":"String", + "desc":"the bus of aliyun eventbridge.", + "required":true + }, + "AccessKeyId":{ + "type":"String", + "desc":"the accessKeyId of aliyun eventbridge.", + "required":true + }, + "AccessKeySecret":{ + "type":"String", + "desc":"the accessKeySecret of aliyun eventbridge.", + "required":true + } + }','{ + "data":"{\"form\":\"JSONPATH\",\"value\":\"$.data\"}", + "id":"{\"form\":\"JSONPATH\",\"value\":\"$.id\"}", + "type":"{\"form\":\"JSONPATH\",\"value\":\"$.type\"}", + "specversion":"{\"form\":\"JSONPATH\",\"value\":\"$. specversion\"}", + "subject":"{\"form\":\"JSONPATH\",\"value\":\"$.subject\"}", + "source":"{\"form\":\"JSONPATH\",\"value\":\"$.source\"}" +}','{ + "aliyuneventbusname":"${AliyunEventBus}", + "accessKeyId":"${AccessKeyId}", + "accessKeySecret":"${AccessKeySecret}", + "accountEndpoint":"${AliyunAccountId}.eventbridge.${RegionId}.aliyuncs.com", + "class":"org.apache.rocketmq.connect.eventbridge.sink.EventBridgeSinkConnector" + }',NULL,'aliyun eventbridge connector config',now(),now());