第98章数据库云服务集成

课程目录第98章数据库云服务集成

98、数据库云服务集成：AWS RDS/Azure SQL/阿里云RDS、C语言SDK、云监控

说实话，做了十几年嵌入式数据库开发，我越来越觉得「纯本地」的方案快撑不住了。尤其是物联网设备一多，数据要汇总、要分析、要备份，本地那点存储和算力根本不够看。这时候，把数据库搬到云上就成了必然选择。

这一章，咱们就聊聊怎么用C语言跟三大云数据库——AWS RDS、Azure SQL、阿里云RDS——打交道。说白了，就是让你的嵌入式设备能优雅地往云上读写数据，顺便还能用云监控盯着运行状态。

为什么需要云数据库集成？

你可能要问：我本地跑SQLite跑得好好的，干嘛非要上云？嗯，我当年也这么想。直到有一次，客户要求所有设备的数据必须实时同步到总部，而且还要做7×24小时的异常告警。本地数据库根本扛不住这种并发和存储需求。

云数据库的好处很明显：

弹性扩展：数据量大了，点几下鼠标就能扩容
高可用：云厂商帮你做了主备切换、自动故障恢复
全球部署：设备在哪儿，数据节点就能部署到哪儿
监控告警：CPU、内存、连接数、慢查询，一目了然

但代价也很直接——你得学会跟云API打交道，而且C语言的SDK往往不如Python、Java那么「友好」。不过别怕，咱们一步步来。

三大云数据库的C语言SDK概览

先看一张总览图，帮你快速建立全局认知：

AWS RDS + C语言集成

AWS RDS支持MySQL、PostgreSQL、MariaDB等多种引擎。C语言这边，最直接的方式是用MySQL Connector/C或者libpq（PostgreSQL）。

我个人习惯用MySQL Connector/C，因为它稳定、文档全。不过要注意一点：AWS RDS默认开启TLS加密，所以连接时得配好证书。

核心要点：连接AWS RDS时，必须使用SSL/TLS，否则会被拒绝。证书可以从AWS官方下载。

下面是一个简单的连接示例：

#include <mysql/mysql.h>
#include <stdio.h>

int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;

    conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init failed\n");
        return 1;
    }

    // 启用SSL
    mysql_ssl_set(conn, NULL, NULL, "rds-ca-2019-root.pem", NULL, NULL);

    // 连接RDS实例
    if (mysql_real_connect(conn, "your-instance.xxxxxx.rds.amazonaws.com",
                           "admin", "your_password", "testdb", 3306, NULL, 0) == NULL) {
        fprintf(stderr, "mysql_real_connect failed: %s\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }

    printf("Connected to AWS RDS successfully!\n");

    // 执行查询
    if (mysql_query(conn, "SELECT * FROM sensor_data LIMIT 10")) {
        fprintf(stderr, "Query failed: %s\n", mysql_error(conn));
    } else {
        res = mysql_store_result(conn);
        while ((row = mysql_fetch_row(res)) != NULL) {
            printf("id=%s, value=%s, ts=%s\n", row[0], row[1], row[2]);
        }
        mysql_free_result(res);
    }

    mysql_close(conn);
    return 0;
}

避坑指南：我曾经在连接AWS RDS时忘了配SSL，结果一直报「Access denied」。折腾了半天才发现是TLS的问题。记住：AWS RDS强制要求SSL，别想着偷懒。

Azure SQL + C语言集成

Azure SQL用的是SQL Server引擎，C语言这边可以用ODBC或者FreeTDS。我个人更推荐ODBC，因为它是标准接口，换数据库时改动小。

Azure SQL的连接字符串比较长，而且同样要求TLS。下面是一个ODBC示例：

#include <sql.h>
#include <sqlext.h>
#include <stdio.h>

int main() {
    SQLHENV henv;
    SQLHDBC hdbc;
    SQLRETURN ret;

    // 分配环境句柄
    SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
    SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, 0);

    // 分配连接句柄
    SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);

    // 连接字符串
    SQLCHAR connStr[] = "DRIVER={ODBC Driver 18 for SQL Server};"
                        "SERVER=tcp:your-server.database.windows.net,1433;"
                        "DATABASE=testdb;"
                        "UID=admin;"
                        "PWD=your_password;"
                        "Encrypt=yes;"
                        "TrustServerCertificate=no;";

    ret = SQLDriverConnect(hdbc, NULL, connStr, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_COMPLETE);
    if (SQL_SUCCEEDED(ret)) {
        printf("Connected to Azure SQL successfully!\n");
    } else {
        printf("Connection failed!\n");
        return 1;
    }

    // 执行查询
    SQLHSTMT hstmt;
    SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
    SQLExecDirect(hstmt, (SQLCHAR*)"SELECT * FROM sensor_data", SQL_NTS);

    SQLCHAR id[32], value[32], ts[32];
    while (SQLFetch(hstmt) == SQL_SUCCESS) {
        SQLGetData(hstmt, 1, SQL_C_CHAR, id, sizeof(id), NULL);
        SQLGetData(hstmt, 2, SQL_C_CHAR, value, sizeof(value), NULL);
        SQLGetData(hstmt, 3, SQL_C_CHAR, ts, sizeof(ts), NULL);
        printf("id=%s, value=%s, ts=%s\n", id, value, ts);
    }

    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
    SQLDisconnect(hdbc);
    SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
    SQLFreeHandle(SQL_HANDLE_ENV, henv);
    return 0;
}

注意：Azure SQL的ODBC驱动版本很重要。我遇到过用旧版驱动连不上新版Azure SQL的情况。建议用ODBC Driver 18 for SQL Server，这是目前最稳定的。

阿里云RDS + C语言集成

阿里云RDS支持MySQL、PostgreSQL、SQL Server等。C语言这边，同样可以用MySQL Connector/C或者libpq。连接方式跟AWS RDS类似，但有几个细节不同：

阿里云RDS默认开启SSL，但可以关闭（不推荐）
内网连接走私网IP，速度更快，延迟更低
外网连接需要白名单授权

下面是一个连接阿里云RDS MySQL的示例：

#include <mysql/mysql.h>
#include <stdio.h>

int main() {
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        fprintf(stderr, "mysql_init failed\n");
        return 1;
    }

    // 阿里云RDS建议开启SSL
    mysql_ssl_set(conn, NULL, NULL, "aliyun-ca-cert.pem", NULL, NULL);

    // 连接阿里云RDS
    if (mysql_real_connect(conn, "your-instance.mysql.rds.aliyuncs.com",
                           "root", "your_password", "testdb", 3306, NULL, 0) == NULL) {
        fprintf(stderr, "Connection failed: %s\n", mysql_error(conn));
        mysql_close(conn);
        return 1;
    }

    printf("Connected to Alibaba Cloud RDS successfully!\n");

    // 插入数据
    if (mysql_query(conn, "INSERT INTO sensor_data (device_id, value) VALUES ('dev001', 23.5)")) {
        fprintf(stderr, "Insert failed: %s\n", mysql_error(conn));
    } else {
        printf("Insert OK, affected rows: %lu\n", mysql_affected_rows(conn));
    }

    mysql_close(conn);
    return 0;
}

个人经验：阿里云RDS的内网连接延迟通常在1ms以内，外网则可能到10-20ms。如果你的设备跟RDS在同一个地域，一定要用内网地址。我曾经有个项目没注意这个，结果外网延迟导致数据同步慢了3倍。

云监控集成

数据库上云之后，监控就成了刚需。三大云厂商都提供了丰富的监控指标：

监控指标	AWS CloudWatch	Azure Monitor	阿里云CloudMonitor
CPU使用率	✓	✓	✓
内存使用率	✓	✓	✓
数据库连接数	✓	✓	✓
慢查询数量	✓	✓	✓
磁盘IOPS	✓	✓	✓
网络吞吐量	✓	✓	✓

在C语言中集成云监控，通常有两种方式：

直接调用云厂商的监控API：通过HTTPS请求获取指标数据
使用SDK封装：部分云厂商提供C语言的监控SDK

我个人更推荐第一种方式，因为API是通用的，不依赖特定SDK版本。下面是一个通过HTTPS获取AWS CloudWatch指标的伪代码示例：

// 伪代码：通过HTTPS获取CloudWatch指标
#include <curl/curl.h>

int get_cloudwatch_metric(const char* instance_id) {
    CURL *curl = curl_easy_init();
    if (!curl) return -1;

    // 构造请求URL（实际需要签名）
    char url[512];
    snprintf(url, sizeof(url),
             "https://monitoring.%s.amazonaws.com/?"
             "Action=GetMetricStatistics&"
             "MetricName=CPUUtilization&"
             "Namespace=AWS/RDS&"
             "Period=300&"
             "Statistics.Average=1&"
             "Dimensions.member.1.Name=DBInstanceIdentifier&"
             "Dimensions.member.1.Value=%s",
             "us-east-1", instance_id);

    curl_easy_setopt(curl, CURLOPT_URL, url);
    // 设置SSL证书、签名等...
    // 发送请求并解析XML/JSON响应

    curl_easy_cleanup(curl);
    return 0;
}

核心建议：云监控的数据最好定期拉取（比如每5分钟一次），然后存入本地数据库做历史分析。这样即使网络断了，你也能看到最近一段时间的趋势。

实战中的避坑指南

最后，分享几个我在项目中踩过的坑：

连接池管理：嵌入式设备资源有限，不要每次请求都新建连接。我习惯用一个简单的连接池，复用已有的连接。
超时设置：云数据库的网络延迟比本地大得多。一定要设置连接超时和读写超时，否则设备可能卡死。
数据压缩：如果传输的数据量大，建议用zlib压缩后再发送。我在一个项目中试过，带宽占用直接降了70%。
重试机制：网络抖动是常态。写代码时一定要加指数退避重试，别一失败就放弃。

好了，这一章的内容就到这里。云数据库集成其实没那么神秘，说白了就是「本地连远程」——只不过多了SSL、签名、监控这些附加项。你只要把基础流程走通，剩下的就是根据业务需求做优化了。

📚 课程目录

98、数据库云服务集成：AWS RDS/Azure SQL/阿里云RDS、C语言SDK、云监控

为什么需要云数据库集成？

三大云数据库的C语言SDK概览

AWS RDS + C语言集成

Azure SQL + C语言集成

阿里云RDS + C语言集成

云监控集成

实战中的避坑指南