diff --git a/src/backend/ci/core/common/common-pipeline/src/main/kotlin/com/tencent/devops/common/pipeline/event/ProjectPipelineCallBack.kt b/src/backend/ci/core/common/common-pipeline/src/main/kotlin/com/tencent/devops/common/pipeline/event/ProjectPipelineCallBack.kt
index 2290891a8c05..53adcb5a5ab4 100644
--- a/src/backend/ci/core/common/common-pipeline/src/main/kotlin/com/tencent/devops/common/pipeline/event/ProjectPipelineCallBack.kt
+++ b/src/backend/ci/core/common/common-pipeline/src/main/kotlin/com/tencent/devops/common/pipeline/event/ProjectPipelineCallBack.kt
@@ -48,5 +48,7 @@ data class ProjectPipelineCallBack(
     @get:Schema(title = "回调是否启用", required = false)
     val failureTime: LocalDateTime? = null,
     @get:Schema(title = "凭证参数", required = false)
-    val secretParam: ISecretParam? = null
+    val secretParam: ISecretParam? = null,
+    @get:Schema(title = "回调名称", required = false)
+    val name: String? = null
 )
diff --git a/src/backend/ci/core/process/api-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResource.kt b/src/backend/ci/core/process/api-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResource.kt
index c2aee27ef0c0..f71e6baec2da 100644
--- a/src/backend/ci/core/process/api-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResource.kt
+++ b/src/backend/ci/core/process/api-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResource.kt
@@ -197,4 +197,22 @@ interface ServiceCallBackResource {
         pipelineId: String,
         callbackInfo: PipelineCallbackEvent
     ): Result<Boolean>
+
+    @Operation(summary = "流水线级别callback")
+    @GET
+    @Path("/projects/{projectId}/pipelines/{pipelineId}")
+    fun getPipelineCallBack(
+        @Parameter(description = "用户ID", required = true, example = AUTH_HEADER_USER_ID_DEFAULT_VALUE)
+        @HeaderParam(AUTH_HEADER_USER_ID)
+        userId: String,
+        @Parameter(description = "projectId", required = true)
+        @PathParam("projectId")
+        projectId: String,
+        @Parameter(description = "pipelineId", required = true)
+        @PathParam("pipelineId")
+        pipelineId: String,
+        @Parameter(description = "事件类型", required = false)
+        @QueryParam("event")
+        event: CallBackEvent?
+    ): Result<List<ProjectPipelineCallBack>>
 }
diff --git a/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/dao/PipelineCallbackDao.kt b/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/dao/PipelineCallbackDao.kt
new file mode 100644
index 000000000000..ae50d6155441
--- /dev/null
+++ b/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/dao/PipelineCallbackDao.kt
@@ -0,0 +1,121 @@
+/*
+ * Tencent is pleased to support the open source community by making BK-CI 蓝鲸持续集成平台 available.
+ *
+ * Copyright (C) 2019 THL A29 Limited, a Tencent company.  All rights reserved.
+ *
+ * BK-CI 蓝鲸持续集成平台 is licensed under the MIT license.
+ *
+ * A copy of the MIT License is included in this file.
+ *
+ *
+ * Terms of the MIT License:
+ * ---------------------------------------------------
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated
+ * documentation files (the "Software"), to deal in the Software without restriction, including without limitation the
+ * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
+ * permit persons to whom the Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all copies or substantial portions of
+ * the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
+ * LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
+ * NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+ * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+ * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+
+package com.tencent.devops.process.dao
+
+import com.tencent.devops.common.pipeline.event.CallBackNetWorkRegionType
+import com.tencent.devops.common.pipeline.event.PipelineCallbackEvent
+import com.tencent.devops.model.process.tables.TPipelineCallback
+import com.tencent.devops.model.process.tables.records.TPipelineCallbackRecord
+import org.jooq.DSLContext
+import org.jooq.Result
+import org.springframework.stereotype.Repository
+import java.time.LocalDateTime
+
+@Suppress("ALL")
+@Repository
+class PipelineCallbackDao {
+
+    /**
+     * 可直接更新或插入
+     */
+    fun save(
+        dslContext: DSLContext,
+        projectId: String,
+        pipelineId: String,
+        userId: String,
+        list: List<PipelineCallbackEvent>
+    ) {
+        if (list.isEmpty()) return
+        with(TPipelineCallback.T_PIPELINE_CALLBACK) {
+            val now = LocalDateTime.now()
+            list.forEach {
+                dslContext.insertInto(
+                    this,
+                    PROJECT_ID,
+                    PIPELINE_ID,
+                    NAME,
+                    EVENT_TYPE,
+                    USER_ID,
+                    URL,
+                    SECRET_TOKEN,
+                    REGION,
+                    CREATE_TIME,
+                    UPDATE_TIME
+                ).values(
+                    projectId,
+                    pipelineId,
+                    it.callbackName,
+                    it.callbackEvent.name,
+                    userId,
+                    it.callbackUrl,
+                    it.secretToken,
+                    (it.region ?: CallBackNetWorkRegionType.IDC).name,
+                    now,
+                    now
+                ).onDuplicateKeyUpdate()
+                    .set(UPDATE_TIME, now)
+                    .set(URL, it.callbackUrl)
+                    .set(SECRET_TOKEN, it.secretToken)
+                    .execute()
+            }
+        }
+    }
+
+    fun list(
+        dslContext: DSLContext,
+        projectId: String,
+        pipelineId: String,
+        event: String? = null
+    ): Result<TPipelineCallbackRecord> {
+        with(TPipelineCallback.T_PIPELINE_CALLBACK) {
+            return dslContext.selectFrom(this)
+                .where(PROJECT_ID.eq(projectId))
+                .let {
+                    if (!event.isNullOrBlank()) {
+                        it.and(EVENT_TYPE.eq(event))
+                    } else it
+                }
+                .fetch()
+        }
+    }
+
+    fun delete(
+        dslContext: DSLContext,
+        projectId: String,
+        pipelineId: String,
+        names: Set<String>
+    ) {
+        with(TPipelineCallback.T_PIPELINE_CALLBACK) {
+            dslContext.deleteFrom(this)
+                .where(PROJECT_ID.eq(projectId))
+                .and(PIPELINE_ID.eq(pipelineId))
+                .and(NAME.`in`(names))
+                .execute()
+        }
+    }
+}
diff --git a/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt b/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt
index 9dfb28a48e6b..50f27f1bbfbf 100644
--- a/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt
+++ b/src/backend/ci/core/process/biz-base/src/main/kotlin/com/tencent/devops/process/engine/service/PipelineRepositoryService.kt
@@ -33,6 +33,7 @@ import com.tencent.devops.common.api.constant.CommonMessageCode
 import com.tencent.devops.common.api.exception.DependNotFoundException
 import com.tencent.devops.common.api.exception.ErrorCodeException
 import com.tencent.devops.common.api.exception.InvalidParamException
+import com.tencent.devops.common.api.util.AESUtil
 import com.tencent.devops.common.api.util.JsonUtil
 import com.tencent.devops.common.api.util.MessageUtil
 import com.tencent.devops.common.api.util.Watcher
@@ -52,6 +53,9 @@ import com.tencent.devops.common.pipeline.enums.BranchVersionAction
 import com.tencent.devops.common.pipeline.enums.ChannelCode
 import com.tencent.devops.common.pipeline.enums.PipelineInstanceTypeEnum
 import com.tencent.devops.common.pipeline.enums.VersionStatus
+import com.tencent.devops.common.pipeline.event.CallBackEvent
+import com.tencent.devops.common.pipeline.event.CallBackNetWorkRegionType
+import com.tencent.devops.common.pipeline.event.PipelineCallbackEvent
 import com.tencent.devops.common.pipeline.extend.ModelCheckPlugin
 import com.tencent.devops.common.pipeline.option.MatrixControlOption
 import com.tencent.devops.common.pipeline.pojo.BuildNo
@@ -72,6 +76,7 @@ import com.tencent.devops.common.service.utils.LogUtils
 import com.tencent.devops.common.web.utils.I18nUtil
 import com.tencent.devops.process.constant.ProcessMessageCode
 import com.tencent.devops.process.constant.ProcessMessageCode.BK_FIRST_STAGE_ENV_NOT_EMPTY
+import com.tencent.devops.process.dao.PipelineCallbackDao
 import com.tencent.devops.process.dao.PipelineSettingDao
 import com.tencent.devops.process.dao.PipelineSettingVersionDao
 import com.tencent.devops.process.dao.label.PipelineViewGroupDao
@@ -124,6 +129,7 @@ import com.tencent.devops.project.api.service.ServiceAllocIdResource
 import org.jooq.DSLContext
 import org.jooq.impl.DSL
 import org.slf4j.LoggerFactory
+import org.springframework.beans.factory.annotation.Value
 import org.springframework.stereotype.Service
 import java.time.LocalDateTime
 import java.util.concurrent.atomic.AtomicInteger
@@ -166,7 +172,8 @@ class PipelineRepositoryService constructor(
     private val redisOperation: RedisOperation,
     private val pipelineYamlInfoDao: PipelineYamlInfoDao,
     private val pipelineGroupService: PipelineGroupService,
-    private val pipelineAsCodeService: PipelineAsCodeService
+    private val pipelineAsCodeService: PipelineAsCodeService,
+    private val pipelineCallbackDao: PipelineCallbackDao
 ) {
 
     companion object {
@@ -217,6 +224,9 @@ class PipelineRepositoryService constructor(
         }
     }
 
+    @Value("\${project.callback.secretParam.aes-key:project_callback_aes_key}")
+    private val aesKey = ""
+
     fun deployPipeline(
         model: Model,
         projectId: String,
@@ -834,6 +844,14 @@ class PipelineRepositoryService constructor(
                 // 初始化流水线构建统计表
                 pipelineBuildSummaryDao.create(dslContext, projectId, pipelineId, buildNo)
                 pipelineModelTaskDao.batchSave(transactionContext, modelTasks)
+                // 初始化流水线单体回调
+                savePipelineCallback(
+                    events = model.events,
+                    pipelineId = pipelineId,
+                    userId = userId,
+                    projectId = projectId,
+                    dslContext = transactionContext
+                )
             }
         } finally {
             lock.unlock()
@@ -1130,6 +1148,14 @@ class PipelineRepositoryService constructor(
                             pipelineId = pipelineId
                         )
                         pipelineModelTaskDao.batchSave(transactionContext, modelTasks)
+                        // 保存流水线单体回调记录
+                        savePipelineCallback(
+                            dslContext = transactionContext,
+                            projectId = projectId,
+                            pipelineId = pipelineId,
+                            userId = userId,
+                            events = model.events
+                        )
                     }
                 }
 
@@ -1353,6 +1379,25 @@ class PipelineRepositoryService constructor(
                 }
             }
         }
+        pipelineCallbackDao.list(
+            dslContext = dslContext,
+            projectId = projectId,
+            pipelineId = pipelineId,
+            event = null
+        ).let { records ->
+            if (records.isNotEmpty) {
+                // 填充流水线级别回调
+                resource?.model?.events = records.associate {
+                    it.name to PipelineCallbackEvent(
+                        callbackEvent = CallBackEvent.valueOf(it.eventType),
+                        callbackUrl = it.url,
+                        secretToken = it.secretToken?.let { AESUtil.decrypt(aesKey, it) },
+                        region = CallBackNetWorkRegionType.valueOf(it.region),
+                        callbackName = it.name
+                    )
+                }
+            }
+        }
         return resource
     }
 
@@ -2166,4 +2211,41 @@ class PipelineRepositoryService constructor(
             null
         }?.handoverFrom
     }
+
+    /**
+     * 保存流水线单体回调记录
+     */
+    private fun savePipelineCallback(
+        events: Map<String, PipelineCallbackEvent>?,
+        pipelineId: String,
+        projectId: String,
+        dslContext: DSLContext,
+        userId: String
+    ) {
+        if (events.isNullOrEmpty()) return
+        val existEventNames = pipelineCallbackDao.list(
+            dslContext = dslContext,
+            projectId = projectId,
+            pipelineId = pipelineId
+        ).map { it.name }.toSet()
+        if (existEventNames.isNotEmpty()) {
+            val needDelNames = existEventNames.subtract(events.keys).toSet()
+            pipelineCallbackDao.delete(
+                dslContext = dslContext,
+                projectId = projectId,
+                pipelineId = pipelineId,
+                names = needDelNames
+            )
+        }
+        // 保存回调事件
+        pipelineCallbackDao.save(
+            dslContext = dslContext,
+            projectId = projectId,
+            pipelineId = pipelineId,
+            userId = userId,
+            list = events.map { (key, value) ->
+                value.copy(secretToken = value.secretToken?.let { AESUtil.encrypt(aesKey, it) })
+            }
+        )
+    }
 }
diff --git a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResourceImpl.kt b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResourceImpl.kt
index e309984f44c3..cae70802bb62 100644
--- a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResourceImpl.kt
+++ b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/api/service/ServiceCallBackResourceImpl.kt
@@ -170,4 +170,19 @@ class ServiceCallBackResourceImpl @Autowired constructor(
         )
         return Result(true)
     }
+
+    override fun getPipelineCallBack(
+        userId: String,
+        projectId: String,
+        pipelineId: String,
+        event: CallBackEvent?
+    ): Result<List<ProjectPipelineCallBack>> {
+        return Result(
+            projectPipelineCallBackService.getPipelineCallback(
+                projectId = projectId,
+                pipelineId = pipelineId,
+                event = event?.name
+            )
+        )
+    }
 }
diff --git a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/control/CallBackControl.kt b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/control/CallBackControl.kt
index 66f47f473452..e5f4813b35c9 100644
--- a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/control/CallBackControl.kt
+++ b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/control/CallBackControl.kt
@@ -226,9 +226,24 @@ class CallBackControl @Autowired constructor(
                 events = callBackEvent.name
             )
         )
-        val pipelineCallback = pipelineRepositoryService.getPipelineResourceVersion(projectId, pipelineId)
-            ?.model
-            ?.getPipelineCallBack(projectId, callBackEvent) ?: emptyList()
+        // 流水线级别回调，旧数据存在model中，新数据存在数据库中
+        val pipelineCallback = projectPipelineCallBackService.getPipelineCallback(
+            projectId = projectId,
+            pipelineId = pipelineId,
+            event = callBackEvent.name
+        ).let {
+            if (it.isEmpty()) {
+                pipelineRepositoryService.getPipelineResourceVersion(
+                    projectId = projectId,
+                    pipelineId = pipelineId
+                )?.model?.getPipelineCallBack(
+                    projectId = projectId,
+                    callbackEvent = callBackEvent
+                ) ?: emptyList()
+            } else {
+                it
+            }
+        }
         if (pipelineCallback.isNotEmpty()) {
             list.addAll(pipelineCallback)
         }
diff --git a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/service/ProjectPipelineCallBackService.kt b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/service/ProjectPipelineCallBackService.kt
index 31b339e231ac..4032d61782dc 100644
--- a/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/service/ProjectPipelineCallBackService.kt
+++ b/src/backend/ci/core/process/biz-process/src/main/kotlin/com/tencent/devops/process/engine/service/ProjectPipelineCallBackService.kt
@@ -56,6 +56,7 @@ import com.tencent.devops.common.service.utils.HomeHostUtil
 import com.tencent.devops.notify.api.service.ServiceNotifyMessageTemplateResource
 import com.tencent.devops.notify.pojo.SendNotifyMessageTemplateRequest
 import com.tencent.devops.process.constant.ProcessMessageCode
+import com.tencent.devops.process.dao.PipelineCallbackDao
 import com.tencent.devops.process.dao.ProjectPipelineCallbackDao
 import com.tencent.devops.process.dao.ProjectPipelineCallbackHistoryDao
 import com.tencent.devops.process.permission.PipelinePermissionService
@@ -63,13 +64,13 @@ import com.tencent.devops.process.pojo.CallBackHeader
 import com.tencent.devops.process.pojo.CreateCallBackResult
 import com.tencent.devops.process.pojo.PipelineNotifyTemplateEnum
 import com.tencent.devops.process.pojo.ProjectPipelineCallBackHistory
-import com.tencent.devops.process.pojo.setting.PipelineModelVersion
 import com.tencent.devops.project.api.service.ServiceAllocIdResource
 import com.tencent.devops.project.api.service.ServiceProjectResource
 import okhttp3.MediaType.Companion.toMediaTypeOrNull
 import okhttp3.Request
 import okhttp3.RequestBody
 import org.jooq.DSLContext
+import org.jooq.impl.DSL
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.beans.factory.annotation.Value
@@ -89,7 +90,8 @@ class ProjectPipelineCallBackService @Autowired constructor(
     private val projectPipelineCallBackUrlGenerator: ProjectPipelineCallBackUrlGenerator,
     private val client: Client,
     private val pipelineRepositoryService: PipelineRepositoryService,
-    private val pipelinePermissionService: PipelinePermissionService
+    private val pipelinePermissionService: PipelinePermissionService,
+    private val pipelineCallbackDao: PipelineCallbackDao
 ) {
 
     @Value("\${project.callback.secretParam.aes-key:project_callback_aes_key}")
@@ -560,19 +562,37 @@ class ProjectPipelineCallBackService @Autowired constructor(
             // 若key存在会覆盖原来的value,否则就是追加新key
             newEventMap[callbackInfo.callbackName] = callbackInfo
         }
-        model.events = newEventMap
-        val newModel = mutableListOf<PipelineModelVersion>()
-        newModel.add(
-            PipelineModelVersion(
-                pipelineId = pipelineId,
+        dslContext.transaction { transactionContext ->
+            val transaction = DSL.using(transactionContext)
+            pipelineCallbackDao.save(
+                dslContext = transaction,
                 projectId = projectId,
-                model = JsonUtil.toJson(model, formatted = false),
-                creator = model.pipelineCreator ?: userId
+                pipelineId = pipelineId,
+                userId = userId,
+                list = newEventMap.map { (key, value) ->
+                    val encodeToken = value.secretToken?.let { AESUtil.encrypt(aesKey, it) }
+                    value.copy(secretToken = encodeToken)
+                }
             )
-        )
-        pipelineRepositoryService.batchUpdatePipelineModel(
-            userId = userId,
-            pipelineModelVersionList = newModel
+        }
+    }
+
+    fun getPipelineCallback(
+        projectId: String,
+        pipelineId: String,
+        event: String?
+    ) = pipelineCallbackDao.list(
+        dslContext = dslContext,
+        projectId = projectId,
+        pipelineId = pipelineId,
+        event = event
+    ).map {
+        ProjectPipelineCallBack(
+            projectId = it.projectId,
+            callBackUrl = it.url,
+            events = it.eventType,
+            secretToken = it.secretToken?.let { AESUtil.decrypt(aesKey, it) },
+            name = it.name
         )
     }
 
diff --git a/src/backend/ci/core/process/biz-process/src/test/kotlin/com/tencent/devops/process/engine/control/CallBackControlTest.kt b/src/backend/ci/core/process/biz-process/src/test/kotlin/com/tencent/devops/process/engine/control/CallBackControlTest.kt
index b64f6c1c90ba..b0006b0b09d0 100644
--- a/src/backend/ci/core/process/biz-process/src/test/kotlin/com/tencent/devops/process/engine/control/CallBackControlTest.kt
+++ b/src/backend/ci/core/process/biz-process/src/test/kotlin/com/tencent/devops/process/engine/control/CallBackControlTest.kt
@@ -164,6 +164,13 @@ class CallBackControlTest : TestBase() {
                 events = events.toString()
             )
         } returns (callbacks!!)
+        every {
+            projectPipelineCallBackService.getPipelineCallback(
+                projectId = projectId,
+                pipelineId = pipelineId,
+                event = events.toString()
+            )
+        } returns (listOf())
     }
 
     @Test
diff --git a/support-files/sql/1001_ci_process_ddl_mysql.sql b/support-files/sql/1001_ci_process_ddl_mysql.sql
index 32afeb6823db..39de6e48efec 100644
--- a/support-files/sql/1001_ci_process_ddl_mysql.sql
+++ b/support-files/sql/1001_ci_process_ddl_mysql.sql
@@ -1283,4 +1283,17 @@ CREATE TABLE IF NOT EXISTS `T_PIPELINE_WEBHOOK_VERSION`
     UNIQUE UNI_PROJECT_PIPELINE_TASK (`PROJECT_ID`, `PIPELINE_ID`, `VERSION`, `TASK_ID`)
 ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COMMENT = '流水线webhook版本';
 
+CREATE TABLE IF NOT EXISTS `T_PIPELINE_CALLBACK` (
+     `PROJECT_ID` varchar(64) NOT NULL COMMENT '蓝盾项目ID',
+     `PIPELINE_ID` varchar(64) NOT NULL COMMENT '流水线ID',
+     `NAME` varchar(255) NOT NULL COMMENT '回调名称',
+     `EVENT_TYPE` varchar(64) NOT NULL COMMENT '事件类型',
+     `REGION` varchar(32) DEFAULT NULL COMMENT '网络域',
+     `URL` varchar(256) NOT NULL COMMENT '回调地址',
+     `SECRET_TOKEN` varchar(100) DEFAULT NULL COMMENT '鉴权参数',
+     `USER_ID` varchar(100) DEFAULT NULL COMMENT '创建人',
+     `CREATE_TIME` datetime DEFAULT NULL COMMENT '创建时间',
+     `UPDATE_TIME` datetime DEFAULT NULL COMMENT '更新时间',
+     PRIMARY KEY (`PROJECT_ID`,`PIPELINE_ID`,`NAME`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 SET FOREIGN_KEY_CHECKS = 1;