如何通过Python向GeoServer上传GeoJSON及.shp文件？

既然手动能上传，说明GeoServer本身支持这些格式，完全可以通过Python调用GeoServer的REST API实现自动化上传，核心是用HTTP请求模拟手动上传的流程。

前提准备 #

• 确保GeoServer已启用REST API（默认开启，可在GeoServer管理界面「服务」-「REST」中确认）。
• 安装Python的requests库，用于发送HTTP请求：

  pip install requests
  

• 拥有GeoServer管理员权限账号（需具备创建数据存储、上传文件的权限）。

一、上传GeoJSON文件 #

GeoServer的REST API支持直接上传GeoJSON到指定数据存储，步骤如下：

1. 基础上传代码 #

import requests
from requests.auth import HTTPBasicAuth

# GeoServer配置信息，替换为你的实际参数
GEOSERVER_URL = "http://你的GeoServer地址:端口/geoserver"
USERNAME = "admin"
PASSWORD = "geoserver"
WORKSPACE = "你的工作区名称"
DATASTORE = "你的数据存储名称"  # 需提前创建，或通过下方代码自动创建
GEOJSON_PATH = "/本地路径/目标文件.geojson"

# 上传GeoJSON的API端点
upload_url = f"{GEOSERVER_URL}/rest/workspaces/{WORKSPACE}/datastores/{DATASTORE}/file.geojson"

# 构造请求参数
headers = {"Content-type": "application/json"}
files = {"file": open(GEOJSON_PATH, "rb")}

# 发送上传请求
response = requests.put(
    upload_url,
    auth=HTTPBasicAuth(USERNAME, PASSWORD),
    files=files,
    headers=headers
)

# 检查上传结果
if response.status_code in [200, 201]:
    print("GeoJSON上传成功")
else:
    print(f"上传失败，状态码：{response.status_code}，响应内容：{response.text}")

2. 自动创建GeoJSON数据存储 #

如果目标数据存储不存在，可先通过API创建：

create_store_url = f"{GEOSERVER_URL}/rest/workspaces/{WORKSPACE}/datastores"

# 数据存储配置模板
store_config = {
    "dataStore": {
        "name": DATASTORE,
        "type": "GeoJSON",
        "connectionParameters": {
            "entry": [{"@key": "url", "$": f"file:data/{WORKSPACE}/{DATASTORE}.geojson"}]
        }
    }
}

# 发送创建请求
create_response = requests.post(
    create_store_url,
    auth=HTTPBasicAuth(USERNAME, PASSWORD),
    json=store_config,
    headers={"Content-type": "application/json"}
)

if create_response.status_code == 201:
    print("数据存储创建成功")
else:
    print(f"数据存储创建失败：{create_response.text}")

二、上传Shapefile文件 #

Shapefile由多个关联文件（.shp、.shx、.dbf等）组成，需先打包为ZIP压缩包再上传：

1. 基础上传代码 #

import requests
from requests.auth import HTTPBasicAuth
import zipfile
import os

# GeoServer配置信息，替换为你的实际参数
GEOSERVER_URL = "http://你的GeoServer地址:端口/geoserver"
USERNAME = "admin"
PASSWORD = "geoserver"
WORKSPACE = "你的工作区名称"
DATASTORE = "你的Shapefile数据存储名称"
SHP_DIR = "/本地Shapefile文件所在目录"  # 需包含所有关联文件
ZIP_PATH = "/临时路径/shapefile_temp.zip"

# 1. 将Shapefile相关文件打包为ZIP
with zipfile.ZipFile(ZIP_PATH, "w") as zipf:
    for file in os.listdir(SHP_DIR):
        # 仅打包Shapefile必要文件
        if file.lower().endswith(('.shp', '.shx', '.dbf', '.prj')):
            zipf.write(os.path.join(SHP_DIR, file), file)

# 2. 上传ZIP文件的API端点
upload_url = f"{GEOSERVER_URL}/rest/workspaces/{WORKSPACE}/datastores/{DATASTORE}/file.shp"

# 发送上传请求
files = {"file": open(ZIP_PATH, "rb")}
response = requests.put(
    upload_url,
    auth=HTTPBasicAuth(USERNAME, PASSWORD),
    files=files
)

# 检查上传结果
if response.status_code in [200, 201]:
    print("Shapefile上传成功")
else:
    print(f"上传失败，状态码：{response.status_code}，响应内容：{response.text}")

# 可选：删除临时ZIP文件
os.remove(ZIP_PATH)

2. 自动创建Shapefile数据存储 #

如需自动创建Shapefile类型的数据存储，配置如下：

create_store_url = f"{GEOSERVER_URL}/rest/workspaces/{WORKSPACE}/datastores"

store_config = {
    "dataStore": {
        "name": DATASTORE,
        "type": "Shapefile",
        "connectionParameters": {
            "entry": [{"@key": "url", "$": f"file:data/{WORKSPACE}/{DATASTORE}"}]
        }
    }
}

create_response = requests.post(
    create_store_url,
    auth=HTTPBasicAuth(USERNAME, PASSWORD),
    json=store_config,
    headers={"Content-type": "application/json"}
)

if create_response.status_code == 201:
    print("Shapefile数据存储创建成功")
else:
    print(f"创建失败：{create_response.text}")

常见问题排查 #

• 认证失败：检查用户名、密码是否正确，确保账号拥有REST和数据存储编辑权限。
• 文件错误：确认本地文件路径正确，ZIP包包含Shapefile所有必要关联文件（.shp/.shx/.dbf缺一不可）。
• 资源不存在：先通过API或手动创建对应的工作区和数据存储，再执行上传。
• 格式问题：确保GeoJSON为标准格式，Shapefile的投影信息（.prj文件）完整。

内容的提问来源于stack exchange，提问作者Juan Carlos Gonzalez Quesada