使用 Apache AGE 加载 CSV 文件：绕过本地文件路径限制的解决方案-js教程-PHP中文网

使用 Apache AGE 加载 CSV 文件：绕过本地文件路径限制的解决方案

心靈之曲

发布： 2025-11-16 15:42:48

原创

425人浏览过

使用 apache age 加载 csv 文件：绕过本地文件路径限制的解决方案

本文介绍了在使用 Apache AGE 构建图时，如何绕过 `load_labels_from_file` 函数对本地文件路径的依赖。通过在服务器端创建上传接口，将 CSV 文件存储在服务器上，并使用服务器端的路径加载数据，从而解决了浏览器安全限制带来的问题。

在使用 Apache AGE 构建图数据库时，经常需要从 CSV 文件中导入数据以创建节点和边。Apache AGE 提供了 load_labels_from_file 函数来实现这一功能，但该函数要求提供 CSV 文件的本地路径。由于浏览器安全限制，JavaScript 无法直接访问用户的本地文件系统，因此直接在前端调用该函数是不可能的。

解决方案：服务器端文件上传与路径传递

为了解决这个问题，一种常见的做法是在服务器端创建一个文件上传接口。其核心思路是：

前端文件上传: 用户通过浏览器选择 CSV 文件，前端 JavaScript 代码将文件上传到服务器。
服务器端存储: 服务器接收到文件后，将其存储到服务器的文件系统中（例如，可以创建一个专门用于存储上传文件的目录）。
返回文件路径: 服务器端生成该文件在服务器上的路径，并将此路径返回给前端。
AGE 数据加载: 前端 JavaScript 代码将服务器返回的文件路径传递给后端，后端使用 load_labels_from_file 函数，并提供服务器端的文件路径，从而将 CSV 数据加载到 Apache AGE 图数据库中。

示例代码（Node.js 服务器端）

以下是一个使用 Node.js 和 multer 中间件实现文件上传接口的示例：

const express = require('express');
const multer = require('multer');
const app = express();
const port = 3000;

// 配置 multer 用于文件上传
const storage = multer.diskStorage({
  destination: function (req, file, cb) {
    cb(null, 'uploads/'); // 上传文件存储目录
  },
  filename: function (req, file, cb) {
    cb(null, Date.now() + '-' + file.originalname); // 文件名
  }
});

const upload = multer({ storage: storage });

// 创建上传接口
app.post('/upload', upload.single('csvFile'), (req, res) => {
  if (!req.file) {
    return res.status(400).send('No file uploaded.');
  }

  const filePath = req.file.path; // 获取文件路径
  console.log('File uploaded to:', filePath);

  res.json({ filePath: filePath }); // 返回文件路径
});

app.listen(port, () => {
  console.log(`Server listening at http://localhost:${port}`);
});

登录后复制

前端代码 (JavaScript)

巧文书

巧文书是一款AI写标书、AI写方案的产品。通过自研的先进AI大模型，精准解析招标文件，智能生成投标内容。

查看详情

async function uploadFile() {
  const fileInput = document.getElementById('csvFile');
  const file = fileInput.files[0];

  if (!file) {
    alert('Please select a file.');
    return;
  }

  const formData = new FormData();
  formData.append('csvFile', file);

  try {
    const response = await fetch('/upload', {
      method: 'POST',
      body: formData
    });

    if (!response.ok) {
      throw new Error(`HTTP error! status: ${response.status}`);
    }

    const data = await response.json();
    const filePath = data.filePath;

    // 将 filePath 发送到后端，用于 AGE 数据加载
    console.log('File path on server:', filePath);

    // TODO:  将 filePath 发送到后端，调用 AGE 的 load_labels_from_file 函数
  } catch (error) {
    console.error('Error uploading file:', error);
    alert('Error uploading file.');
  }
}

登录后复制

AGE 数据加载 (PostgreSQL 函数)

在 PostgreSQL 中创建一个函数，用于接收文件路径并执行 load_labels_from_file 函数。

CREATE OR REPLACE FUNCTION load_data_from_csv(graph_name TEXT, label_name TEXT, file_path TEXT)
RETURNS VOID AS $$
BEGIN
  PERFORM load_labels_from_file(graph_name, label_name, file_path, false);
END;
$$ LANGUAGE plpgsql;

登录后复制

注意事项