新增neutron中subnet的删除，修改以及端口的操作

admin · 发表于 2025-11-12 10:33:40

非常好这一步就是把你的 OpenStack Neutron 网络管理模块从「仅网络层」扩展到完整的网络 + 子网 + 端口管理功能。
下面我给你完整规划 + 代码框架（基于你现有的 network_list_view 和 edit_network_view 结构，可直接嵌入项目）。

一、总体架构设计

我们按功能模块划分成三个部分：

networks/
├── views/
│ ├── networks.py    # 网络的增删改查
│ ├── subnets.py    # 子网管理（新增/编辑/删除）
│ ├── ports.py       # 端口管理（创建/删除/绑定安全组/绑定虚机）
│
├── templates/
│ ├── networks.html
│ ├── network_edit.html
│ ├── subnets.html
│ ├── subnet_edit.html
│ ├── ports.html
│ ├── port_edit.html
│
└── urls.py          # 统一注册URL

二、子网管理 Subnets 功能
子网列表
# views/subnets.py
import requests
from django.shortcuts import render, redirect
from django.contrib import messages
from django.views.decorators.csrf import csrf_exempt

@csrf_exempt
def subnet_list_view(request, network_id):
"""查看指定网络的所有子网"""
token = request.session.get("token")
headers = {"X-Auth-Token": token}
resp = requests.get(f"{Neutron_Base}/subnets", headers=headers, timeout=10)

if resp.status_code == 200:
      all_subnets = resp.json().get("subnets", [])
      subnets = [s for s in all_subnets if s["network_id"] == network_id]
else:
      messages.error(request, f"无法获取子网列表: {resp.text}")
      subnets = []

return render(request, "subnets.html", {"subnets": subnets, "network_id": network_id})

新建子网
@csrf_exempt
def subnet_create_view(request, network_id):
if request.method == "POST":
      token = request.session.get("token")
      headers = {"X-Auth-Token": token, "Content-Type": "application/json"}

      name = request.POST.get("name")
      cidr = request.POST.get("cidr")
      gateway_ip = request.POST.get("gateway_ip")
      enable_dhcp = request.POST.get("enable_dhcp") == "on"

      data = {
         "subnet": {
            "network_id": network_id,
            "ip_version": 4,
            "cidr": cidr,
            "gateway_ip": gateway_ip,
            "enable_dhcp": enable_dhcp,
            "name": name,
         }
      }

      resp = requests.post(f"{Neutron_Base}/subnets", headers=headers, json=data, timeout=15)
      if resp.status_code in [200, 201]:
         messages.success(request, "子网创建成功")
      else:
         messages.error(request, f"子网创建失败: {resp.text}")
      return redirect("subnet_list", network_id=network_id)

return render(request, "subnet_edit.html", {"network_id": network_id})

删除子网
def subnet_delete_view(request, subnet_id, network_id):
token = request.session.get("token")
headers = {"X-Auth-Token": token}
resp = requests.delete(f"{Neutron_Base}/subnets/{subnet_id}", headers=headers, timeout=10)

if resp.status_code == 204:
      messages.success(request, "子网已删除")
else:
      messages.error(request, f"删除失败: {resp.text}")
return redirect("subnet_list", network_id=network_id)

三、端口 Ports 管理
端口列表
def port_list_view(request, network_id):
token = request.session.get("token")
headers = {"X-Auth-Token": token}
resp = requests.get(f"{Neutron_Base}/ports", headers=headers, timeout=10)

if resp.status_code == 200:
      ports = [p for p in resp.json().get("ports", []) if p["network_id"] == network_id]
else:
      ports = []
      messages.error(request, f"无法获取端口: {resp.text}")

return render(request, "ports.html", {"ports": ports, "network_id": network_id})

新建端口
@csrf_exempt
def port_create_view(request, network_id):
if request.method == "POST":
      token = request.session.get("token")
      headers = {"X-Auth-Token": token, "Content-Type": "application/json"}

      name = request.POST.get("name")
      data = {
         "port": {
            "network_id": network_id,
            "name": name,
            "admin_state_up": True
         }
      }
      resp = requests.post(f"{Neutron_Base}/ports", headers=headers, json=data, timeout=10)
      if resp.status_code in [200, 201]:
         messages.success(request, "端口创建成功")
      else:
         messages.error(request, f"创建失败: {resp.text}")
      return redirect("port_list", network_id=network_id)

return render(request, "port_edit.html", {"network_id": network_id})

删除端口
def port_delete_view(request, port_id, network_id):
token = request.session.get("token")
headers = {"X-Auth-Token": token}
resp = requests.delete(f"{Neutron_Base}/ports/{port_id}", headers=headers, timeout=10)

if resp.status_code == 204:
      messages.success(request, "端口已删除")
else:
      messages.error(request, f"删除失败: {resp.text}")

return redirect("port_list", network_id=network_id)

4️⃣ 更新安全组绑定
@csrf_exempt
def port_update_sg_view(request, port_id, network_id):
if request.method == "POST":
      token = request.session.get("token")
      headers = {"X-Auth-Token": token, "Content-Type": "application/json"}
      sg_id = request.POST.get("security_group_id")

      data = {"port": {"security_groups": [sg_id]}}
      resp = requests.put(f"{Neutron_Base}/ports/{port_id}", headers=headers, json=data, timeout=10)

      if resp.status_code in [200, 202]:
         messages.success(request, "安全组更新成功")
      else:
         messages.error(request, f"安全组更新失败: {resp.text}")

return redirect("port_list", network_id=network_id)

绑定虚机（实例）接口
@csrf_exempt
def port_bind_instance_view(request, port_id, server_id, network_id):
token = request.session.get("token")
headers = {"X-Auth-Token": token, "Content-Type": "application/json"}

data = {
      "port": {
         "device_id": server_id,
         "device_owner": "compute:nova"
      }
}

resp = requests.put(f"{Neutron_Base}/ports/{port_id}", headers=headers, json=data, timeout=10)
if resp.status_code in [200, 202]:
      messages.success(request, "端口成功绑定到虚机")
else:
      messages.error(request, f"绑定失败: {resp.text}")
return redirect("port_list", network_id=network_id)

四、URL 路由示例
# urls.py
from django.urls import path
from .views import networks, subnets, ports

urlpatterns = [
path("networks/", networks.network_list_view, name="networks"),
path("networks/edit/<str:network_id>/", networks.edit_network_view, name="edit_network"),

path("networks/<str:network_id>/subnets/", subnets.subnet_list_view, name="subnet_list"),
path("networks/<str:network_id>/subnets/create/", subnets.subnet_create_view, name="subnet_create"),
path("networks/<str:network_id>/subnets/delete/<str:subnet_id>/", subnets.subnet_delete_view, name="subnet_delete"),

path("networks/<str:network_id>/ports/", ports.port_list_view, name="port_list"),
path("networks/<str:network_id>/ports/create/", ports.port_create_view, name="port_create"),
path("networks/<str:network_id>/ports/delete/<str:port_id>/", ports.port_delete_view, name="port_delete"),
path("networks/<str:network_id>/ports/update_sg/<str:port_id>/", ports.port_update_sg_view, name="port_update_sg"),
path("networks/<str:network_id>/ports/bind/<str:port_id>/<str:server_id>/", ports.port_bind_instance_view, name="port_bind_instance"),
]

		自动登录	找回密码
密码			注册