如何通过外部设备HTTP POST请求向Google Cloud Database传数据？求教程示例

以下是生产环境常用的实现方案和可直接复用的代码示例，采用「Cloud Functions 做HTTP接入层 + 对应GCP数据库做存储」的架构，无需额外维护服务器。

通用实现流程 #

• 在GCP控制台创建目标数据库实例（支持Firestore、Cloud SQL、Cloud Bigtable等所有GCP数据库产品），配置服务账号的数据库写入权限
• 部署HTTP触发类型的Cloud Function，编写请求校验、数据写入逻辑
• 配置Cloud Function的调用权限（公开调用或下发密钥鉴权），获取触发URL后外部设备即可向该地址发送POST请求上传数据

代码示例 #

以下示例基于Firestore（无模式文档型数据库，无需提前建表）实现，可根据需求替换为其他GCP数据库的写入逻辑。

Node.js 运行环境代码 #

首先在package.json中添加依赖：

{
  "dependencies": {
    "@google-cloud/firestore": "^7.7.0"
  }
}

入口文件index.js代码：

const { Firestore } = require('@google-cloud/firestore');
const firestore = new Firestore();

exports.uploadDeviceData = async (req, res) => {
  // 仅允许POST请求
  if (req.method !== 'POST') {
    return res.status(405).send('Only POST requests are allowed');
  }

  try {
    const { deviceId, timestamp, sensorData } = req.body;
    // 基础参数校验，可根据业务扩展
    if (!deviceId || !timestamp || !sensorData) {
      return res.status(400).send('Missing required parameters: deviceId, timestamp, sensorData');
    }

    // 写入Firestore集合
    const docRef = await firestore.collection('device_data').add({
      deviceId,
      timestamp: new Date(timestamp),
      sensorData,
      uploadTime: new Date()
    });

    return res.status(200).send(`Data uploaded successfully, document ID: ${docRef.id}`);
  } catch (error) {
    console.error('Upload failed:', error);
    return res.status(500).send('Internal server error');
  }
};

Python 运行环境代码 #

首先在requirements.txt中添加依赖：

google-cloud-firestore==2.16.0
flask==2.2.5

入口文件main.py代码：

import google.cloud.firestore
from flask import jsonify

firestore_client = google.cloud.firestore.Client()

def upload_device_data(request):
    if request.method != "POST":
        return "Only POST requests are allowed", 405
    
    request_json = request.get_json()
    required_fields = ["deviceId", "timestamp", "sensorData"]
    if not all(field in request_json for field in required_fields):
        return "Missing required parameters: deviceId, timestamp, sensorData", 400
    
    try:
        doc_ref = firestore_client.collection("device_data").document()
        doc_ref.set({
            "deviceId": request_json["deviceId"],
            "timestamp": request_json["timestamp"],
            "sensorData": request_json["sensorData"],
            "uploadTime": google.cloud.firestore.SERVER_TIMESTAMP
        })
        return jsonify({"status": "success", "documentId": doc_ref.id}), 200
    except Exception as e:
        print(f"Upload failed: {e}")
        return "Internal server error", 500

外部设备调用示例 #

curl -X POST https://<GCP区域>-<你的项目ID>.cloudfunctions.net/uploadDeviceData \
-H "Content-Type: application/json" \
-d '{
  "deviceId": "sensor_001",
  "timestamp": "2024-05-20T12:00:00Z",
  "sensorData": {
    "temperature": 25.6,
    "humidity": 62
  }
}'

生产环境注意事项 #

• 必须添加请求鉴权逻辑，比如校验请求头中的自定义密钥、设备ID白名单，避免恶意请求写入脏数据
• 如果使用Cloud SQL等私有网络部署的数据库，需要为Cloud Function配置VPC访问权限，保证网络连通性
• 数据写入前请做格式和范围校验，避免不符合业务规则的数据插入数据库
• 单请求数据量大于1MB或写入QPS较高时，可先将请求数据推送到Cloud Pub/Sub后异步写入数据库，避免请求超时

内容的提问来源于stack exchange，提问作者Nicola Rigoni