diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java
index 71adef0..63f6920 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/EGEventSubscriptionController.java
@@ -9,6 +9,7 @@ import com.volvo.ai.analytic.center.dto.resp.CompetingBrrandsDTO;
 import com.volvo.ai.analytic.center.dto.resp.ResultDTO;
 import com.volvo.ai.analytic.center.feign.CompetingBrandsClient;
 import com.volvo.ai.analytic.center.service.HuaWeiEGService;
+import io.swagger.annotations.ApiOperation;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -58,6 +59,12 @@ public class EGEventSubscriptionController {
         return ResultDTO.success(huaWeiService.sendEvent(req));
     }
 
+    @ApiOperation(value = "创建目标连接", notes = "创建目标连接", httpMethod = "POST")
+    @PostMapping("/connection")
+    public ResultDTO<CreateConnectionResponse> createConnection(@RequestBody ConnectionCreateReq req) {
+        return ResultDTO.success(huaWeiService.createConnection(req));
+    }
+
     /**
      * 创建事件订阅
      *