diff --git a/packages/api/src/core/connections.ts b/packages/api/src/core/connections.ts
index 1abef289b..ccd83d5aa 100644
--- a/packages/api/src/core/connections.ts
+++ b/packages/api/src/core/connections.ts
@@ -28,6 +28,22 @@ export function batchUpdateConnectionTags(params: any) {
   return requestClient.patch(`${BASE_URL}/batchUpdateListtags`, params)
 }
 
+export interface BatchUpdateConnectionAgentSettingsParams {
+  requestId: string
+  connectionIds: string[]
+  settings: {
+    accessNodeType: string
+    accessNodeProcessId: string | null
+    priorityProcessId: string | null
+  }
+}
+
+export function batchUpdateConnectionAgentSettings(
+  params: BatchUpdateConnectionAgentSettingsParams,
+) {
+  return requestClient.patch(`${BASE_URL}/batch-agent-settings`, params)
+}
+
 export function checkConnection(id: string, params: any) {
   return requestClient.patch(`${BASE_URL}/${id}`, params)
 }
diff --git a/packages/business/src/locale/lang/en.js b/packages/business/src/locale/lang/en.js
index 241143d96..1e349e90f 100644
--- a/packages/business/src/locale/lang/en.js
+++ b/packages/business/src/locale/lang/en.js
@@ -68,6 +68,11 @@ export default {
   packages_business_priorityProcessId: 'Tag-Based Scheduling',
   packages_business_connection_form_access_node_tip:
     'When using the automatic mode, the platform will assign nodes for connection access, while in manual mode, the user is responsible for manually specifying the nodes for access',
+  packages_business_connections_list_batch_agent_settings:
+    'Batch Agent Settings',
+  packages_business_agent_settings_dialog_title: 'Batch Agent Settings',
+  packages_business_agent_settings_dialog_subtitle:
+    'The same Agent settings will be prepared for {count} selected connections.',
   packages_business_connection_form_give_up: 'Give Up',
   packages_business_share_form_setting_table_name: 'Store MongoDB table name',
   packages_business_share_form_setting_log_time: 'Log save time',
diff --git a/packages/business/src/locale/lang/zh-CN.js b/packages/business/src/locale/lang/zh-CN.js
index 7a7608eb2..4d1c17b22 100644
--- a/packages/business/src/locale/lang/zh-CN.js
+++ b/packages/business/src/locale/lang/zh-CN.js
@@ -65,6 +65,10 @@ export default {
   packages_business_priorityProcessId: '标签内调度方式',
   packages_business_connection_form_access_node_tip:
     '自动情况下由平台分配节点进行连接访问，手动情况下由用户手动指定节点进行访问',
+  packages_business_connections_list_batch_agent_settings: '批量设置 Agent',
+  packages_business_agent_settings_dialog_title: '批量设置 Agent',
+  packages_business_agent_settings_dialog_subtitle:
+    '将为选中的 {count} 个连接生成相同的 Agent 设置。',
   packages_business_connection_form_give_up: '放弃',
   packages_business_share_form_setting_table_name: '存储MongoDB表名',
   packages_business_share_form_setting_log_time: '日志保存时长',
diff --git a/packages/business/src/locale/lang/zh-TW.js b/packages/business/src/locale/lang/zh-TW.js
index 419d483fd..b0603cc4b 100644
--- a/packages/business/src/locale/lang/zh-TW.js
+++ b/packages/business/src/locale/lang/zh-TW.js
@@ -65,6 +65,10 @@ export default {
   packages_business_priorityProcessId: '標籤內調度方式',
   packages_business_connection_form_access_node_tip:
     '自動情況下由平台分配節點進行連接訪問，手動情況下由用戶手動指定節點進行訪問',
+  packages_business_connections_list_batch_agent_settings: '批量設定 Agent',
+  packages_business_agent_settings_dialog_title: '批量設定 Agent',
+  packages_business_agent_settings_dialog_subtitle:
+    '將為選取的 {count} 個連接產生相同的 Agent 設定。',
   packages_business_connection_form_give_up: '放棄',
   packages_business_share_form_setting_table_name: '存儲MongoDB表名',
   packages_business_share_form_setting_log_time: '日誌保存時長',
diff --git a/packages/business/src/views/connections/BatchAgentSettingsDialog.vue b/packages/business/src/views/connections/BatchAgentSettingsDialog.vue
new file mode 100644
index 000000000..a51644662
--- /dev/null
+++ b/packages/business/src/views/connections/BatchAgentSettingsDialog.vue
@@ -0,0 +1,181 @@
+<script setup lang="ts">
+import { action } from '@formily/reactive'
+import SchemaToForm from '@tap/form/src/SchemaToForm.vue'
+import { useI18n } from '@tap/i18n'
+import { uuid } from '@tap/shared'
+import { computed, ref } from 'vue'
+import {
+  AGENT_GROUP_ALLOCATION,
+  AUTOMATIC_AGENT_ALLOCATION,
+  MANUAL_AGENT_ALLOCATION,
+  createAgentSettingsProperties,
+  loadAccessNodeOptions,
+  type AgentAllocationType,
+  type BatchAgentSettingsPayload,
+} from './agentSettingsSchema'
+
+interface ConnectionRow {
+  id: string
+  name?: string
+  shareCdcEnable?: boolean
+}
+
+const emit = defineEmits<{
+  submit: [payload: BatchAgentSettingsPayload]
+}>()
+
+const { t } = useI18n()
+const isDaas = import.meta.env.VUE_APP_PLATFORM === 'DAAS'
+const visible = ref(false)
+const selectedConnections = ref<ConnectionRow[]>([])
+const schemaForm = ref<InstanceType<typeof SchemaToForm> | null>(null)
+const formValues = ref<Record<string, any>>({})
+const formKey = ref(0)
+
+const schema = computed(() => ({
+  type: 'object',
+  properties: {
+    __TAPDATA: {
+      type: 'object',
+      properties: {
+        shareCdcEnable: {
+          type: 'boolean',
+          'x-display': 'hidden',
+        },
+        shareCDCExternalStorageId: {
+          type: 'string',
+          'x-display': 'hidden',
+        },
+        ...createAgentSettingsProperties((key) => t(key), isDaas),
+      },
+    },
+  },
+}))
+
+const formScope = {
+  $isDaas: isDaas,
+  useAsyncDataSource: (
+    service: (...args: any[]) => Promise<any>,
+    fieldName = 'dataSource',
+    ...serviceParams: any[]
+  ) => {
+    return (field: any) => {
+      field.loading = true
+      service({ field }, ...serviceParams).then(
+        action.bound((data) => {
+          if (fieldName === 'value') {
+            field.setValue(data)
+          } else {
+            field[fieldName] = data
+          }
+          field.loading = false
+        }),
+      )
+    }
+  },
+  loadAccessNode: loadAccessNodeOptions,
+}
+
+const open = (connections: ConnectionRow[]) => {
+  selectedConnections.value = [...connections]
+  const hasSharedCdcConnection = connections.some(
+    (connection) => connection.shareCdcEnable,
+  )
+  const requiresManualAgent = !isDaas && hasSharedCdcConnection
+
+  formValues.value = {
+    __TAPDATA: {
+      shareCdcEnable: hasSharedCdcConnection,
+      shareCDCExternalStorageId: '',
+      accessNodeType: requiresManualAgent
+        ? MANUAL_AGENT_ALLOCATION
+        : AUTOMATIC_AGENT_ALLOCATION,
+      accessNodeProcessId: '',
+      priorityProcessId: '',
+    },
+  }
+  formKey.value += 1
+  visible.value = true
+}
+
+const handleClose = () => {
+  visible.value = false
+  selectedConnections.value = []
+}
+
+const handleSubmit = async () => {
+  const form = schemaForm.value?.getForm()
+  if (!form) return
+
+  try {
+    await form.validate()
+  } catch {
+    document
+      .querySelector('.formily-element-plus-form-item-error')
+      ?.scrollIntoView({ block: 'center' })
+    return
+  }
+
+  const { __TAPDATA = {} } = schemaForm.value?.getFormValues() || {}
+  const accessNodeType = __TAPDATA.accessNodeType as AgentAllocationType
+  const usesAgent = accessNodeType !== AUTOMATIC_AGENT_ALLOCATION
+  const payload: BatchAgentSettingsPayload = {
+    requestId: uuid(),
+    connectionIds: selectedConnections.value.map(({ id }) => id),
+    settings: {
+      accessNodeType,
+      accessNodeProcessId: usesAgent
+        ? __TAPDATA.accessNodeProcessId || null
+        : null,
+      priorityProcessId:
+        accessNodeType === AGENT_GROUP_ALLOCATION
+          ? __TAPDATA.priorityProcessId || null
+          : null,
+    },
+  }
+
+  emit('submit', payload)
+}
+
+defineExpose({ open, close: handleClose })
+</script>
+
+<template>
+  <ElDialog
+    v-model="visible"
+    :title="t('packages_business_agent_settings_dialog_title')"
+    width="560px"
+    :close-on-click-modal="false"
+    append-to-body
+    destroy-on-close
+    @closed="handleClose"
+  >
+    <div class="mb-4 text-muted">
+      {{
+        t('packages_business_agent_settings_dialog_subtitle', {
+          count: selectedConnections.length,
+        })
+      }}
+    </div>
+    <SchemaToForm
+      :key="formKey"
+      ref="schemaForm"
+      :schema="schema"
+      :scope="formScope"
+      :value="formValues"
+      layout="vertical"
+      label-width="100%"
+      class="w-100"
+    />
+    <template #footer>
+      <ElButton @click="handleClose">{{ t('public_button_cancel') }}</ElButton>
+      <ElButton
+        type="primary"
+        :disabled="!selectedConnections.length"
+        @click="handleSubmit"
+      >
+        {{ t('public_button_confirm') }}
+      </ElButton>
+    </template>
+  </ElDialog>
+</template>
diff --git a/packages/business/src/views/connections/DatabaseForm.vue b/packages/business/src/views/connections/DatabaseForm.vue
index 319f46c56..6a70fac2d 100644
--- a/packages/business/src/views/connections/DatabaseForm.vue
+++ b/packages/business/src/views/connections/DatabaseForm.vue
@@ -1,6 +1,5 @@
 <script>
 import { action } from '@formily/reactive'
-import { findAccessNodeInfo } from '@tap/api/src/core/cluster'
 import {
   createConnection,
   getUsingDigginTaskByConnectionId,
@@ -35,6 +34,10 @@ import PageContainer from '../../components/PageContainer.vue'
 import { ConnectionDebug } from './ConnectionDebug'
 import { JsDebug } from './JsDebug'
 import Test from './Test.vue'
+import {
+  createAgentSettingsProperties,
+  loadAccessNodeOptions,
+} from './agentSettingsSchema'
 import UsedTaskDialog from './UsedTaskDialog.vue'
 import { getConnectionIcon } from './util'
 
@@ -652,217 +655,7 @@ export default {
       }
 
       Object.assign(endProperties, {
-        accessNodeType: {
-          type: 'string',
-          title: this.$t('packages_business_connection_form_access_node'),
-          default: 'AUTOMATIC_PLATFORM_ALLOCATION',
-          'x-decorator': 'FormItem',
-          'x-decorator-props': {
-            tooltip: this.$t(
-              'packages_business_connection_form_access_node_tip',
-            ),
-          },
-          'x-component': 'Select',
-          enum: [
-            {
-              label: this.$t('packages_business_connection_form_automatic'),
-              value: 'AUTOMATIC_PLATFORM_ALLOCATION',
-            },
-            {
-              label: this.$t('packages_business_connection_form_manual'),
-              value: 'MANUALLY_SPECIFIED_BY_THE_USER',
-            },
-          ],
-          'x-reactions': [
-            {
-              dependencies: ['__TAPDATA.shareCdcEnable'],
-              fulfill: {
-                state: {
-                  value: `{{!$isDaas && $deps[0] ? 'MANUALLY_SPECIFIED_BY_THE_USER' : $self.value}}`,
-                  dataSource: `{{!$isDaas && $deps[0] ? [
-                    { label: '${this.$t(
-                      'packages_business_connection_form_automatic',
-                    )}', value: 'AUTOMATIC_PLATFORM_ALLOCATION', disabled: true },
-                    { label: '${this.$t(
-                      'packages_business_connection_form_manual',
-                    )}', value: 'MANUALLY_SPECIFIED_BY_THE_USER' }
-                  ] : !$isDaas ? [
-                    { label: '${this.$t(
-                      'packages_business_connection_form_automatic',
-                    )}', value: 'AUTOMATIC_PLATFORM_ALLOCATION' },
-                    { label: '${this.$t(
-                      'packages_business_connection_form_manual',
-                    )}', value: 'MANUALLY_SPECIFIED_BY_THE_USER' }
-                  ] : [
-                    { label: '${this.$t(
-                      'packages_business_connection_form_automatic',
-                    )}', value: 'AUTOMATIC_PLATFORM_ALLOCATION' },
-                    { label: '${this.$t(
-                      'packages_business_connection_form_manual',
-                    )}', value: 'MANUALLY_SPECIFIED_BY_THE_USER' },
-                    {
-                      label: '${this.$t('packages_business_connection_form_group')}',
-                      value: 'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP'
-                    }
-                  ]}}`,
-                },
-              },
-            },
-            {
-              target: '__TAPDATA.accessNodeProcessId',
-              effects: ['onFieldInputValueChange'],
-              fulfill: {
-                state: {
-                  value: '',
-                  // value: `{{console.log("$target.dataSource", $target.dataSource), $target.value ? '' : $target.dataSource && $target.dataSource[0] ? $target.dataSource[0].value : ''}}`
-                },
-              },
-            },
-          ],
-        },
-        accessNodeOption: {
-          type: 'string',
-          'x-display': 'hidden',
-          'x-reactions': [
-            {
-              dependencies: ['.accessNodeType'],
-              fulfill: {
-                state: {
-                  visible:
-                    "{{['MANUALLY_SPECIFIED_BY_THE_USER', 'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP'].includes($deps[0])}}",
-                },
-              },
-            },
-            '{{useAsyncDataSource(loadAccessNode, "dataSource", {value: $self.value})}}',
-          ],
-        },
-        agentWrap: {
-          type: 'void',
-          'x-component': 'Space',
-          'x-component-props': {
-            class: 'w-100 align-items-start',
-          },
-          'x-reactions': {
-            dependencies: ['.accessNodeType'],
-            fulfill: {
-              state: {
-                visible:
-                  "{{['MANUALLY_SPECIFIED_BY_THE_USER', 'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP'].includes($deps[0])}}",
-              },
-            },
-          },
-          properties: {
-            accessNodeProcessId: {
-              type: 'string',
-              description: `{{$values.__TAPDATA.shareCdcEnable ? '${this.$t(
-                'packages_business_agent_select_not_found_for_rocksdb',
-              )}' : ''}}`,
-              'x-decorator': 'FormItem',
-              'x-decorator-props': {
-                colon: false,
-                class: 'flex-1',
-              },
-              'x-component': 'Select',
-              'x-component-props': {
-                onChange: `{{ () => $self.setSelfErrors('') }}`,
-              },
-              'x-reactions': [
-                // '{{useAsyncDataSource(loadAccessNode, "dataSource", {value: $self.value})}}',
-                // 根据下拉数据判断是否存在已选的agent
-                {
-                  dependencies: [
-                    '.accessNodeType',
-                    '.accessNodeOption#dataSource',
-                  ],
-                  fulfill: {
-                    state: {
-                      title: `{{'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP' === $deps[0] ? '${i18n.t(
-                        'packages_business_choose_agent_group',
-                      )}': '${i18n.t('packages_business_choose_agent')}'}}`,
-                    },
-                    run: `
-                console.log('$deps[1]', $deps)
-                if (!$deps[1]) return
-                $self.dataSource = $deps[1].filter(item => item.accessNodeType === $deps[0])
-                if ($self.dataSource?.length) {
-                // $self.dataSource = $deps[1].filter(item => item.accessNodeType === $deps[0])
-                if ($self.value) {
-                  const current = $self.dataSource.find(item => item.value === $self.value)
-                  if (!current) {
-                    $self.setSelfErrors('${this.$t('packages_business_agent_select_not_found')}')
-                  }
-                }
-              }`,
-                  },
-                },
-              ],
-              // 校验下拉数据判断是否存在已选的agent
-              'x-validator': `{{(value, rule, ctx)=> {
-            if (!value) {
-              let msg = '${this.$t('packages_business_agent_select_placeholder')}'
-              const {shareCDCExternalStorageId} = $values.__TAPDATA
-              if (shareCDCExternalStorageId) {
-                const dataSource = $form.query('__TAPDATA.shareCDCExternalStorageId').get('dataSource')
-                const type = dataSource.find(item => item.value === shareCDCExternalStorageId)?.type
-                if (type === 'rocksdb') msg = '${this.$t('packages_business_agent_select_not_found_for_rocksdb')}'
-              }
-              return msg
-            } else if (value && ctx.field.dataSource?.length) {
-              const current = ctx.field.dataSource.find(item => item.value === value)
-              if (!current) {
-                $self.setSelfErrors('')
-                return '${this.$t('packages_business_agent_select_not_found')}'
-              }
-            }
-          }}}`,
-            },
-            priorityProcessId: {
-              title: i18n.t('packages_business_priorityProcessId'),
-              type: 'string',
-              default: '',
-              'x-decorator': 'FormItem',
-              'x-decorator-props': {
-                class: 'flex-1',
-              },
-              'x-component': 'Select',
-              'x-reactions': {
-                dependencies: [
-                  '.accessNodeType',
-                  '.accessNodeOption#dataSource',
-                  '.accessNodeProcessId',
-                ],
-                fulfill: {
-                  state: {
-                    visible:
-                      "{{'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP' === $deps[0]}}",
-                  },
-                  run: `
-                    let children = []
-
-                    if ($deps[1] && $deps[2]) {
-                      const item = $deps[1].find(item => item.accessNodeType === $deps[0] && item.value === $deps[2])
-                      if (item) {
-                        children = item.children || []
-                      }
-                    }
-
-                    $self.dataSource = [
-                      {
-                        label:'${i18n.t('packages_business_connection_form_automatic')}',
-                        value: ''
-                      }
-                    ].concat(children)
-
-                    if ($self.value && !children.find(item => item.value === $self.value)) {
-                      $self.value = ''
-                    }
-                  `,
-                },
-              },
-            },
-          },
-        },
-
+        ...createAgentSettingsProperties((key) => this.$t(key), this.isDaas),
         schemaUpdateHour: {
           type: 'string',
           title: i18n.t(
@@ -982,10 +775,6 @@ export default {
           label: i18n.t('packages_business_connections_databaseform_system'),
           value: 'default',
         })
-        endProperties.accessNodeType.enum.push({
-          label: this.$t('packages_business_connection_form_group'),
-          value: 'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP',
-        })
       }
 
       const connectionProperties =
@@ -1351,48 +1140,7 @@ export default {
             )
           }
         },
-        loadAccessNode: async (fieldName, others = {}) => {
-          const data = await findAccessNodeInfo()
-
-          const mapNode = (item) => ({
-            value: item.processId,
-            label: `${item.agentName || item.hostName}（${
-              item.status === 'running'
-                ? i18n.t('public_status_running')
-                : i18n.t('public_agent_status_offline')
-            }）`,
-            disabled: item.status !== 'running',
-            accessNodeType: item.accessNodeType,
-          })
-
-          return (
-            data
-              ?.filter(
-                (t) =>
-                  t.status === 'running' ||
-                  t.accessNodeType ===
-                    'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP' ||
-                  t.processId === others.value,
-              )
-              ?.map((item) => {
-                if (
-                  item.accessNodeType ===
-                  'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP'
-                ) {
-                  return {
-                    value: item.processId,
-                    label: `${item.accessNodeName}（${i18n.t('public_status_running')}：${
-                      item.accessNodes?.filter((ii) => ii.status === 'running')
-                        .length || 0
-                    }）`,
-                    accessNodeType: item.accessNodeType,
-                    children: item.accessNodes?.map(mapNode) || [],
-                  }
-                }
-                return mapNode(item)
-              }) || []
-          )
-        },
+        loadAccessNode: loadAccessNodeOptions,
         loadCommandList: async (filter, val) => {
           try {
             const { $values, command, where = {}, page, size } = filter
diff --git a/packages/business/src/views/connections/List.vue b/packages/business/src/views/connections/List.vue
index c3d39bc7b..1c856513e 100644
--- a/packages/business/src/views/connections/List.vue
+++ b/packages/business/src/views/connections/List.vue
@@ -1,6 +1,7 @@
 <script setup lang="ts">
 import {
   batchUpdateConnectionTags,
+  batchUpdateConnectionAgentSettings,
   checkConnectionTask,
   copyConnection,
   deleteConnection,
@@ -37,6 +38,8 @@ import SchemaProgress from '../../components/SchemaProgress.vue'
 import TablePage from '../../components/TablePage.vue'
 import UploadDialog from '../../components/UploadDialog.vue'
 import BatchTagDialog from '../../components/BatchTagDialog.vue'
+import BatchAgentSettingsDialog from './BatchAgentSettingsDialog.vue'
+import type { BatchAgentSettingsPayload } from './agentSettingsSchema'
 import { useHas } from '../../composables'
 import { CONNECTION_STATUS_MAP, CONNECTION_TYPE_MAP } from '../../shared'
 import Preview from './Preview.vue'
@@ -90,6 +93,9 @@ const test = ref()
 const dialog = ref()
 const permissionseSettingsCreate = ref()
 const batchTagDialog = ref<InstanceType<typeof BatchTagDialog> | null>(null)
+const batchAgentSettingsDialog = ref<InstanceType<
+  typeof BatchAgentSettingsDialog
+> | null>(null)
 
 // State
 let timeout: NodeJS.Timeout | null = null
@@ -455,6 +461,26 @@ const openBatchTagDialog = () => {
   batchTagDialog.value?.open(multipleSelection.value as any)
 }
 
+const openBatchAgentSettingsDialog = () => {
+  if (!multipleSelection.value.length) return
+  batchAgentSettingsDialog.value?.open(multipleSelection.value as any)
+}
+
+const handleBatchAgentSettingsSubmit = async (
+  payload: BatchAgentSettingsPayload,
+) => {
+  try {
+    await batchUpdateConnectionAgentSettings(payload)
+    batchAgentSettingsDialog.value?.close()
+    table.value?.clearSelection?.()
+    await table.value?.fetch()
+    ElMessage.success(i18n.t('public_message_save_ok'))
+  } catch (error) {
+    console.error(error)
+    ElMessage.error(i18n.t('packages_business_message_saveFail'))
+  }
+}
+
 const handleBatchTagSaved = () => {
   table.value?.clearSelection?.()
   table.value?.fetch()
@@ -786,26 +812,29 @@ onUnmounted(() => {
           </template>
         </FilterBar>
       </template>
-      <template v-if="isDaas" #multipleSelectionActions>
-        <ElButton @click="handlePermissionsSettings"
+      <template #multipleSelectionActions>
+        <ElButton v-if="isDaas" @click="handlePermissionsSettings"
           >{{
             $t('packages_business_permissionse_settings_create_quanxianshezhi')
           }}
         </ElButton>
+        <ElButton @click="openBatchAgentSettingsDialog">
+          {{ $t('packages_business_connections_list_batch_agent_settings') }}
+        </ElButton>
         <ElButton
+          v-if="isDaas"
           v-readonlybtn="'datasource_category_application'"
           class="btn"
           @click="openBatchTagDialog"
         >
           <span> {{ $t('public_button_bulk_tag') }}</span>
         </ElButton>
-        <ElButton @click="handleExport">
+        <ElButton v-if="isDaas" @click="handleExport">
           <el-icon><i-lucide-download /></el-icon>
           <span> {{ $t('public_button_export') }}</span>
         </ElButton>
       </template>
       <ElTableColumn
-        v-if="isDaas"
         type="selection"
         width="32"
         align="center"
@@ -1013,6 +1042,10 @@ onUnmounted(() => {
       @saved="handleBatchTagSaved"
       @tag-created="handleBatchTagCreated"
     />
+    <BatchAgentSettingsDialog
+      ref="batchAgentSettingsDialog"
+      @submit="handleBatchAgentSettingsSubmit"
+    />
     <Preview
       ref="previewRef"
       @test="testConnection"
diff --git a/packages/business/src/views/connections/agentSettingsSchema.ts b/packages/business/src/views/connections/agentSettingsSchema.ts
new file mode 100644
index 000000000..a3558eb93
--- /dev/null
+++ b/packages/business/src/views/connections/agentSettingsSchema.ts
@@ -0,0 +1,293 @@
+import { findAccessNodeInfo } from '@tap/api/src/core/cluster'
+import i18n from '@tap/i18n'
+
+export const AUTOMATIC_AGENT_ALLOCATION = 'AUTOMATIC_PLATFORM_ALLOCATION'
+export const MANUAL_AGENT_ALLOCATION = 'MANUALLY_SPECIFIED_BY_THE_USER'
+export const AGENT_GROUP_ALLOCATION =
+  'MANUALLY_SPECIFIED_BY_THE_USER_AGENT_GROUP'
+
+export type AgentAllocationType =
+  | typeof AUTOMATIC_AGENT_ALLOCATION
+  | typeof MANUAL_AGENT_ALLOCATION
+  | typeof AGENT_GROUP_ALLOCATION
+
+export interface AgentSettingsValues {
+  accessNodeType: AgentAllocationType
+  accessNodeProcessId: string | null
+  priorityProcessId: string | null
+}
+
+export interface BatchAgentSettingsPayload {
+  requestId: string
+  connectionIds: string[]
+  settings: AgentSettingsValues
+}
+
+interface AgentInfo {
+  processId?: string
+  agentName?: string
+  hostName?: string
+  status?: string
+  accessNodeType?: string
+  accessNodeName?: string
+  accessNodes?: AgentInfo[]
+}
+
+interface AgentOption {
+  value: string
+  label: string
+  disabled?: boolean
+  accessNodeType?: string
+  children?: AgentOption[]
+}
+
+type Translate = (key: string) => string
+
+export function createAgentSettingsProperties(
+  t: Translate,
+  isDaas: boolean,
+): Record<string, any> {
+  const automaticLabel = JSON.stringify(
+    t('packages_business_connection_form_automatic'),
+  )
+  const manualLabel = JSON.stringify(
+    t('packages_business_connection_form_manual'),
+  )
+  const groupLabel = JSON.stringify(
+    t('packages_business_connection_form_group'),
+  )
+  const chooseAgentLabel = JSON.stringify(t('packages_business_choose_agent'))
+  const chooseAgentGroupLabel = JSON.stringify(
+    t('packages_business_choose_agent_group'),
+  )
+  const agentRequiredMessage = JSON.stringify(
+    t('packages_business_agent_select_placeholder'),
+  )
+  const agentNotFoundMessage = JSON.stringify(
+    t('packages_business_agent_select_not_found'),
+  )
+  const rocksdbAgentMessage = JSON.stringify(
+    t('packages_business_agent_select_not_found_for_rocksdb'),
+  )
+
+  const options = isDaas
+    ? `[
+        { label: ${automaticLabel}, value: '${AUTOMATIC_AGENT_ALLOCATION}' },
+        { label: ${manualLabel}, value: '${MANUAL_AGENT_ALLOCATION}' },
+        { label: ${groupLabel}, value: '${AGENT_GROUP_ALLOCATION}' }
+      ]`
+    : `[
+        { label: ${automaticLabel}, value: '${AUTOMATIC_AGENT_ALLOCATION}' },
+        { label: ${manualLabel}, value: '${MANUAL_AGENT_ALLOCATION}' }
+      ]`
+
+  return {
+    accessNodeType: {
+      type: 'string',
+      title: t('packages_business_connection_form_access_node'),
+      default: AUTOMATIC_AGENT_ALLOCATION,
+      'x-decorator': 'FormItem',
+      'x-decorator-props': {
+        tooltip: t('packages_business_connection_form_access_node_tip'),
+      },
+      'x-component': 'Select',
+      enum: [
+        {
+          label: t('packages_business_connection_form_automatic'),
+          value: AUTOMATIC_AGENT_ALLOCATION,
+        },
+        {
+          label: t('packages_business_connection_form_manual'),
+          value: MANUAL_AGENT_ALLOCATION,
+        },
+        ...(isDaas
+          ? [
+              {
+                label: t('packages_business_connection_form_group'),
+                value: AGENT_GROUP_ALLOCATION,
+              },
+            ]
+          : []),
+      ],
+      'x-reactions': [
+        {
+          dependencies: ['__TAPDATA.shareCdcEnable'],
+          fulfill: {
+            state: {
+              value: `{{!$isDaas && $deps[0] ? '${MANUAL_AGENT_ALLOCATION}' : $self.value}}`,
+              dataSource: `{{!$isDaas && $deps[0] ? [
+                { label: ${automaticLabel}, value: '${AUTOMATIC_AGENT_ALLOCATION}', disabled: true },
+                { label: ${manualLabel}, value: '${MANUAL_AGENT_ALLOCATION}' }
+              ] : !$isDaas ? [
+                { label: ${automaticLabel}, value: '${AUTOMATIC_AGENT_ALLOCATION}' },
+                { label: ${manualLabel}, value: '${MANUAL_AGENT_ALLOCATION}' }
+              ] : ${options}}}`,
+            },
+          },
+        },
+        {
+          target: '__TAPDATA.accessNodeProcessId',
+          effects: ['onFieldInputValueChange'],
+          fulfill: {
+            state: {
+              value: '',
+            },
+          },
+        },
+      ],
+    },
+    accessNodeOption: {
+      type: 'string',
+      'x-display': 'hidden',
+      'x-reactions': [
+        {
+          dependencies: ['.accessNodeType'],
+          fulfill: {
+            state: {
+              visible: `{{['${MANUAL_AGENT_ALLOCATION}', '${AGENT_GROUP_ALLOCATION}'].includes($deps[0])}}`,
+            },
+          },
+        },
+        '{{useAsyncDataSource(loadAccessNode, "dataSource", {value: $self.value})}}',
+      ],
+    },
+    agentWrap: {
+      type: 'void',
+      'x-component': 'Space',
+      'x-component-props': {
+        class: 'w-100 align-items-start',
+      },
+      'x-reactions': {
+        dependencies: ['.accessNodeType'],
+        fulfill: {
+          state: {
+            visible: `{{['${MANUAL_AGENT_ALLOCATION}', '${AGENT_GROUP_ALLOCATION}'].includes($deps[0])}}`,
+          },
+        },
+      },
+      properties: {
+        accessNodeProcessId: {
+          type: 'string',
+          description: `{{$values.__TAPDATA.shareCdcEnable ? ${rocksdbAgentMessage} : ''}}`,
+          'x-decorator': 'FormItem',
+          'x-decorator-props': {
+            colon: false,
+            class: 'flex-1',
+          },
+          'x-component': 'Select',
+          'x-component-props': {
+            onChange: "{{ () => $self.setSelfErrors('') }}",
+          },
+          'x-reactions': [
+            {
+              dependencies: ['.accessNodeType', '.accessNodeOption#dataSource'],
+              fulfill: {
+                state: {
+                  title: `{{'${AGENT_GROUP_ALLOCATION}' === $deps[0] ? ${chooseAgentGroupLabel} : ${chooseAgentLabel}}}`,
+                },
+                run: `
+                  if (!$deps[1]) return
+                  $self.dataSource = $deps[1].filter(item => item.accessNodeType === $deps[0])
+                  if ($self.value && $self.dataSource.length && !$self.dataSource.some(item => item.value === $self.value)) {
+                    $self.setSelfErrors(${agentNotFoundMessage})
+                  }
+                `,
+              },
+            },
+          ],
+          'x-validator': `{{(value, rule, ctx) => {
+            if (!value) {
+              let msg = ${agentRequiredMessage}
+              const { shareCDCExternalStorageId } = $values.__TAPDATA
+              if (shareCDCExternalStorageId) {
+                const dataSource = $form.query('__TAPDATA.shareCDCExternalStorageId').get('dataSource')
+                const type = dataSource.find(item => item.value === shareCDCExternalStorageId)?.type
+                if (type === 'rocksdb') msg = ${rocksdbAgentMessage}
+              }
+              return msg
+            } else if (ctx.field.dataSource?.length && !ctx.field.dataSource.some(item => item.value === value)) {
+              $self.setSelfErrors('')
+              return ${agentNotFoundMessage}
+            }
+          }}}`,
+        },
+        priorityProcessId: {
+          title: t('packages_business_priorityProcessId'),
+          type: 'string',
+          default: '',
+          'x-decorator': 'FormItem',
+          'x-decorator-props': {
+            class: 'flex-1',
+          },
+          'x-component': 'Select',
+          'x-reactions': {
+            dependencies: [
+              '.accessNodeType',
+              '.accessNodeOption#dataSource',
+              '.accessNodeProcessId',
+            ],
+            fulfill: {
+              state: {
+                visible: `{{'${AGENT_GROUP_ALLOCATION}' === $deps[0]}}`,
+              },
+              run: `
+                let children = []
+                if ($deps[1] && $deps[2]) {
+                  children = $deps[1].find(item => item.accessNodeType === $deps[0] && item.value === $deps[2])?.children || []
+                }
+                $self.dataSource = [
+                  { label: ${automaticLabel}, value: '' }
+                ].concat(children)
+                if ($self.value && !children.some(item => item.value === $self.value)) {
+                  $self.value = ''
+                }
+              `,
+            },
+          },
+        },
+      },
+    },
+  }
+}
+
+export async function loadAccessNodeOptions(
+  _field: unknown,
+  others: { value?: string } = {},
+): Promise<AgentOption[]> {
+  const data: AgentInfo[] = await findAccessNodeInfo({})
+
+  const mapAgent = (item: AgentInfo): AgentOption => ({
+    value: item.processId || '',
+    label: `${item.agentName || item.hostName}（${
+      item.status === 'running'
+        ? i18n.t('public_status_running')
+        : i18n.t('public_agent_status_offline')
+    }）`,
+    disabled: item.status !== 'running',
+    accessNodeType: item.accessNodeType,
+  })
+
+  return (
+    data
+      ?.filter(
+        (item) =>
+          item.status === 'running' ||
+          item.accessNodeType === AGENT_GROUP_ALLOCATION ||
+          item.processId === others.value,
+      )
+      .map((item) => {
+        if (item.accessNodeType === AGENT_GROUP_ALLOCATION) {
+          return {
+            value: item.processId || '',
+            label: `${item.accessNodeName}（${i18n.t('public_status_running')}：${
+              item.accessNodes?.filter((agent) => agent.status === 'running')
+                .length || 0
+            }）`,
+            accessNodeType: item.accessNodeType,
+            children: item.accessNodes?.map(mapAgent) || [],
+          }
+        }
+        return mapAgent(item)
+      }) || []
+  )
+}