登录/ 注册
 找回密码
 立即注册
关闭

CSDN热搜

程序园 精品问答 技术交流 资源下载
返回列表 发新帖
首页 › 业界区 › 业界 ›ESP32-S3接入大模型API，对话AI

ESP32-S3接入大模型API，对话AI

跑两獗 2025-6-3 10:42:32
ESP32-S3接入大模型API，对话AI

1、先使用python验证可行性
  1. import requests
  3. url = "https://api.siliconflow.cn/v1/chat/completions"
  5. payload = {
  6.     "model": "deepseek-ai/DeepSeek-R1",
  7.     "messages": [  # 必须包含消息内容
  8.         {"role": "user", "content": "请解释量子计算的基本原理"}
  9.     ],
  10.     "stream": False,
  11.     "max_tokens": 512,
  12.     "temperature": 0.7,
  13.     "top_p": 0.7,
  14.     "top_k": 50,
  15.     "frequency_penalty": 0.5,
  16.     "n": 1
  17. }
  18. headers = {
  19.     "Authorization": "Bearer "your api_key"",
  20.     "Content-Type": "application/json"
  21. }
  23. response = requests.request("POST", url, json=payload, headers=headers)
  25. print(response.text)
复制代码
1.png
代码
2.png
3.png
秘钥获取硅基流动注册送14元免费额度，https://cloud.siliconflow.cn/i/9MqV8tO4
邀请码：9MqV8tO4
2、Postman验证POST请求结构，深化熟悉对接流程

4.png
POST请求头（Headers）设置
5.png
POST请求主体（Body）设置Authorization: your api key                                    Content-Type：application/jsonBody:
  1. {
  2.     "model": "deepseek-ai/DeepSeek-V3",
  3.     "messages": [
  4.         {"role": "user", "content": "请解释量子计算的基本原理"}//问题
  5.     ],
  6.     // "stream": False,
  7.     "max_tokens": 512,
  8.     "temperature": 0.7,
  9.     "top_p": 0.7,
  10.     "top_k": 50,
  11.     "frequency_penalty": 0.5,
  12.     "n": 1
  13. }
复制代码
实战！在esp32s3上实现ai对话：

1、使用micro python实现

因为之前验证过python的可行性，而esp32系列可以使用micro python编程，其特点是便捷高效，所以先使用mico python实现。
开发环境
编程调试下载环境：Thonny
编程语言：micro python
前置条件：烧录micro python固件（乐鑫官网中下载）
  1. import network
  2. import time
  3. import urequests
  4. import ujson
  5. from machine import reset
  7. # ====== 配置部分 ======
  8. SSID = 'jianzhiji'
  9. PASSWORD = '8765432111'
  10. API_KEY = "你的api密钥"
  11. API_URL = "https://api.siliconflow.cn/v1/chat/completions"
  13. def connect_wifi():
  14.     wlan = network.WLAN(network.STA_IF)
  15.     wlan.active(True)
  16.    
  17.     if not wlan.isconnected():
  18.         print(f"Connecting to {SSID}...")
  19.         wlan.connect(SSID, PASSWORD)
  20.         
  21.         timeout = 20
  22.         while not wlan.isconnected() and timeout > 0:
  23.             print(".", end="")
  24.             time.sleep(1)
  25.             timeout -= 1
  26.             
  27.         if not wlan.isconnected():
  28.             raise RuntimeError("WiFi连接超时")
  29.    
  30.     print("\nIP Address:", wlan.ifconfig()[0])
  31.     return wlan
  33. def api_request():
  34.     headers = {
  35.         "Authorization": f"Bearer {API_KEY}",
  36.         "Content-Type": "application/json"
  37.     }
  38.    
  39.     # 最小化请求参数
  40.     payload = {
  41.         "model": "deepseek-ai/DeepSeek-V3",
  42.         "messages": [{"role": "user", "content": "hello"}],
  43.         "max_tokens": 512,
  44.         "temperature": 0.7,
  45.         "top_p": 0.7
  46.     }
  47.    
  48.     try:
  49.         print("\n[Request]")
  50.         print("Payload:", payload)
  51.         
  52.         response = urequests.post(
  53.             API_URL,
  54.             headers=headers,
  55.             data=ujson.dumps(payload),
  56.             timeout=20
  57.         )
  58.         
  59.         print(f"\n[Response] Status: {response.status_code}")
  60.         if response.status_code == 200:
  61.             json_resp = response.json()
  62.             print("AI回复:", json_resp['choices'][0]['message']['content'])
  63.         else:
  64.             print("Error Response:", response.text)
  65.             
  66.         response.close()
  67.         
  68.     except Exception as e:
  69.         print("[Error]", str(e))
  71. try:
  72.     print("=== 启动系统 ===")
  73.     connect_wifi()
  74.     api_request()
  75.    
  76. except Exception as e:
  77.     print("\n!!! 错误:", str(e))
  78.     print("10秒后重启...")
  79.     time.sleep(10)
  80.     reset()
复制代码
6.png

2、使用C语言实现

开发环境
编程调试下载环境：VSCOde+espidf插件
编程语言：C
  1. #include <string.h>
  2. #include "esp_log.h"
  3. #include "nvs_flash.h"
  4. #include "esp_event.h"
  5. #include "esp_netif.h"
  6. #include "protocol_examples_common.h"
  7. #include "esp_http_client.h"
  8. #include "esp_sntp.h"
  9. // 在文件开头添加
  10. #include "lwip/apps/sntp.h"
  12. #define MAX_HTTP_OUTPUT_BUFFER 2048
  13. static const char *TAG = "HTTP_AI_CLIENT";
  14. #define API_ENDPOINT "http://api.siliconflow.cn/v1/chat/completions"
  16. // 添加事件处理函数
  17. static esp_err_t http_event_handler(esp_http_client_event_t *evt)
  18. {
  19.     switch (evt->event_id) {
  20.         case HTTP_EVENT_ERROR:
  21.             ESP_LOGI(TAG, "HTTP_EVENT_ERROR");
  22.             break;
  23.         case HTTP_EVENT_ON_CONNECTED:
  24.             ESP_LOGI(TAG, "HTTP_EVENT_ON_CONNECTED");
  25.             break;
  26.         case HTTP_EVENT_HEADERS_SENT:
  27.             ESP_LOGI(TAG, "HTTP_EVENT_HEADERS_SENT");
  28.             break;
  29.         case HTTP_EVENT_ON_HEADER:
  30.             ESP_LOGI(TAG, "HTTP_EVENT_ON_HEADER, key=%s, value=%s", evt->header_key, evt->header_value);
  31.             break;
  32.         case HTTP_EVENT_ON_DATA:
  33.             ESP_LOGI(TAG, "HTTP_EVENT_ON_DATA, len=%d", evt->data_len);
  34.             break;
  35.         case HTTP_EVENT_ON_FINISH:
  36.             ESP_LOGI(TAG, "HTTP_EVENT_ON_FINISH");
  37.             break;
  38.         case HTTP_EVENT_DISCONNECTED:
  39.             ESP_LOGI(TAG, "HTTP_EVENT_DISCONNECTED");
  40.             break;
  41.         default:
  42.             break;
  43.     }
  44.     return ESP_OK;
  45. }
  47. static void http_post_request(void)
  48. {
  49.     char output_buffer[MAX_HTTP_OUTPUT_BUFFER] = {0};
  50.     esp_http_client_config_t config = {
  51.         .url = API_ENDPOINT,
  52.         .event_handler = http_event_handler, // 添加事件处理
  53.         .timeout_ms = 30000,                // 增加超时到30秒
  54.         .skip_cert_common_name_check = true, // 跳过证书CN检查
  55.         .cert_pem = NULL,                   // 不指定证书
  56.     };
  57.     esp_http_client_handle_t client = esp_http_client_init(&config);
  59.     const char *json_data =
  60.     "{"
  61.         ""model": "deepseek-ai/DeepSeek-V3","//选择模型
  62.         ""messages": ["
  63.             "{"
  64.                 ""role": "user","
  65.                 ""content": "你好""//填入问题内容
  66.             "}"
  67.         "],"
  68.         ""max_tokens": 512,"
  69.         ""temperature": 0.7,"
  70.         ""top_p": 0.7,"
  71.         ""top_k": 50,"
  72.         ""frequency_penalty": 0.5,"
  73.         ""n": 1"
  74.     "}";
  76.     esp_http_client_set_method(client, HTTP_METHOD_POST);
  77.     esp_http_client_set_header(client, "Content-Type", "application/json");
  78.     esp_http_client_set_header(client, "Authorization", "your api key");//key_API
  80.     esp_err_t err = esp_http_client_open(client, strlen(json_data));
  81.     if (err != ESP_OK) {
  82.         ESP_LOGE(TAG, "连接失败: %s", esp_err_to_name(err));
  83.         goto cleanup;
  84.     }
  86.     int wlen = esp_http_client_write(client, json_data, strlen(json_data));
  87.     if (wlen < 0) {
  88.         ESP_LOGE(TAG, "数据写入失败");
  89.         goto cleanup;
  90.     }
  92.     int content_length = esp_http_client_fetch_headers(client);
  93.     if (content_length < 0) {
  94.         ESP_LOGE(TAG, "获取头部信息失败");
  95.         goto cleanup;
  96.     }
  98.     int data_read = esp_http_client_read_response(client, output_buffer, MAX_HTTP_OUTPUT_BUFFER);
  99.     if (data_read >= 0) {
  100.         ESP_LOGI(TAG, "HTTP状态码 = %d, 内容长度 = %"PRIu64,
  101.                 esp_http_client_get_status_code(client),
  102.                 esp_http_client_get_content_length(client));
  103.         ESP_LOGI(TAG, "响应内容: %s", output_buffer);
  104.     } else {
  105.         ESP_LOGE(TAG, "读取响应失败");
  106.     }
  108. cleanup:
  109.     esp_http_client_cleanup(client);
  110. }
  112. static void http_task(void *pvParameters)
  113. {
  114.     http_post_request();
  115.     ESP_LOGI(TAG, "HTTP示例完成");
  116.     vTaskDelete(NULL);
  117. }
  119. void app_main(void)
  120. {
  121.     ESP_ERROR_CHECK(nvs_flash_init());
  122.     ESP_ERROR_CHECK(esp_netif_init());
  123.     ESP_ERROR_CHECK(esp_event_loop_create_default());
  124.     ESP_ERROR_CHECK(example_connect());
  126.     sntp_setoperatingmode(SNTP_OPMODE_POLL);
  127.     sntp_setservername(0, "pool.ntp.org");  // 第1个NTP服务器
  128.     sntp_setservername(1, "time.nist.gov"); // 第2个NTP服务器（可选）
  129.     sntp_init();
  130.     // 在 sntp_init() 后添加时间同步等待
  131.     int retry = 0;
  132.     const int retry_count = 10;
  133.     while (sntp_get_sync_status() == SNTP_SYNC_STATUS_RESET && ++retry < retry_count) {
  134.         printf("Waiting for system time to sync... (%d/%d)\n", retry, retry_count);
  135.         vTaskDelay(2000 / portTICK_PERIOD_MS);
  136.     }
  137.     xTaskCreate(&http_task, "http_task", 8192, NULL, 5, NULL);
  138. }
复制代码
终端输出结果
7.png

由于该版本等待时间过短，提问复杂问题时常常等不到回答就提示连接失败。
以下优化版本增加
1、超时策略
2、动态缓冲区扩容
3、分段传输机制
  1. #include <string.h>
  2. #include "esp_log.h"
  3. #include "nvs_flash.h"
  4. #include "esp_event.h"
  5. #include "esp_netif.h"
  6. #include "protocol_examples_common.h"
  7. #include "esp_http_client.h"
  8. #include "esp_sntp.h"
  9. // 在文件开头添加
  10. #include "lwip/apps/sntp.h"
  12. #define MAX_HTTP_OUTPUT_BUFFER 2048
  13. static const char *TAG = "HTTP_AI_CLIENT";
  14. #define API_ENDPOINT "http://api.siliconflow.cn/v1/chat/completions"
  16. // 添加事件处理函数
  17. static esp_err_t http_event_handler(esp_http_client_event_t *evt)
  18. {
  19.     switch (evt->event_id) {
  20.         case HTTP_EVENT_ERROR:
  21.             ESP_LOGI(TAG, "HTTP_EVENT_ERROR");
  22.             break;
  23.         case HTTP_EVENT_ON_CONNECTED:
  24.             ESP_LOGI(TAG, "HTTP_EVENT_ON_CONNECTED");
  25.             break;
  26.         case HTTP_EVENT_HEADERS_SENT:
  27.             ESP_LOGI(TAG, "HTTP_EVENT_HEADERS_SENT");
  28.             break;
  29.         case HTTP_EVENT_ON_HEADER:
  30.             ESP_LOGI(TAG, "HTTP_EVENT_ON_HEADER, key=%s, value=%s", evt->header_key, evt->header_value);
  31.             break;
  32.         case HTTP_EVENT_ON_DATA:
  33.             ESP_LOGI(TAG, "HTTP_EVENT_ON_DATA, len=%d", evt->data_len);
  34.             break;
  35.         case HTTP_EVENT_ON_FINISH:
  36.             ESP_LOGI(TAG, "HTTP_EVENT_ON_FINISH");
  37.             break;
  38.         case HTTP_EVENT_DISCONNECTED:
  39.             ESP_LOGI(TAG, "HTTP_EVENT_DISCONNECTED");
  40.             break;
  41.         default:
  42.             break;
  43.     }
  44.     return ESP_OK;
  45. }
  47. static void http_post_request(void)
  48. {
  49.     // char output_buffer[MAX_HTTP_OUTPUT_BUFFER] = {0};
  50.        // 增大缓冲区防止数据截断
  51.     char *output_buffer = calloc(1, MAX_HTTP_OUTPUT_BUFFER * 2); // 扩容至4096
  52.     if (!output_buffer) {
  53.         ESP_LOGE(TAG, "内存分配失败");
  54.         return;
  55.     }
  56.     esp_http_client_config_t config = {
  57.         .url = API_ENDPOINT,
  58.         .event_handler = http_event_handler,
  59.         .timeout_ms = 120000,                // 超时延长至120秒
  60.         .disable_auto_redirect = false,      // 允许重定向
  61.         .keep_alive_enable = true,           // 启用长连接
  62.         .skip_cert_common_name_check = true,
  63.         .cert_pem = NULL
  64.     };
  65.     esp_http_client_handle_t client = esp_http_client_init(&config);
  67.     const char *json_data =
  68.     "{"
  69.         ""model": "deepseek-ai/DeepSeek-R1","//选择模型
  70.         ""messages": ["
  71.             "{"
  72.                 ""role": "user","
  73.                 ""content": "写一篇散文""//填入问题内容
  74.             "}"
  75.         "],"
  76.         ""max_tokens": 512,"
  77.         ""temperature": 0.7,"
  78.         ""top_p": 0.7,"
  79.         ""top_k": 50,"
  80.         ""frequency_penalty": 0.5,"
  81.         ""n": 1"
  82.     "}";
  84.     esp_http_client_set_method(client, HTTP_METHOD_POST);
  85.     esp_http_client_set_header(client, "Content-Type", "application/json");
  86.     esp_http_client_set_header(client, "Authorization", "  ");//key_API
  88.      // 新增分段接收逻辑
  89.     int total_read = 0;
  90.     esp_err_t err = esp_http_client_open(client, strlen(json_data));
  91.     if (err == ESP_OK) {
  92.         // 分段写入数据（应对大请求体）
  93.         const char *ptr = json_data;
  94.         int remaining = strlen(json_data);
  95.         while (remaining > 0) {
  96.             int written = esp_http_client_write(client, ptr, remaining);
  97.             if (written <= 0) break;
  98.             ptr += written;
  99.             remaining -= written;
  100.         }
  101.     }
  103.     int wlen = esp_http_client_write(client, json_data, strlen(json_data));
  104.     if (wlen < 0) {
  105.         ESP_LOGE(TAG, "数据写入失败");
  106.         goto cleanup;
  107.     }
  109. // 新增分段读取逻辑
  110.     if (esp_http_client_fetch_headers(client) >= 0) {
  111.         int read_len;
  112.         do {
  113.             read_len = esp_http_client_read(client,
  114.                 output_buffer + total_read,
  115.                 MAX_HTTP_OUTPUT_BUFFER * 2 - total_read - 1
  116.             );
  117.             if (read_len > 0) {
  118.                 total_read += read_len;
  119.             }
  120.         } while (read_len > 0);
  121.         
  122.         output_buffer[total_read] = '\0'; // 确保字符串终止
  123.     }
  125.     int data_read = esp_http_client_read_response(client, output_buffer, MAX_HTTP_OUTPUT_BUFFER);
  126.     if (data_read >= 0) {
  127.         ESP_LOGI(TAG, "HTTP状态码 = %d, 内容长度 = %"PRIu64,
  128.                 esp_http_client_get_status_code(client),
  129.                 esp_http_client_get_content_length(client));
  130.         ESP_LOGI(TAG, "响应内容: %s", output_buffer);
  131.     } else {
  132.         ESP_LOGE(TAG, "读取响应失败");
  133.     }
  135. cleanup:
  136.     esp_http_client_cleanup(client);
  137. }
  139. static void http_task(void *pvParameters)
  140. {
  141.     http_post_request();
  142.     ESP_LOGI(TAG, "HTTP示例完成");
  143.     vTaskDelete(NULL);
  144. }
  146. void app_main(void)
  147. {
  148.     ESP_ERROR_CHECK(nvs_flash_init());
  149.     ESP_ERROR_CHECK(esp_netif_init());
  150.     ESP_ERROR_CHECK(esp_event_loop_create_default());
  151.     ESP_ERROR_CHECK(example_connect());
  153.     sntp_setoperatingmode(SNTP_OPMODE_POLL);
  154.     sntp_setservername(0, "pool.ntp.org");  // 第1个NTP服务器
  155.     sntp_setservername(1, "time.nist.gov"); // 第2个NTP服务器（可选）
  156.     sntp_init();
  157.     // 在 sntp_init() 后添加时间同步等待
  158.     int retry = 0;
  159.     const int retry_count = 10;
  160.     while (sntp_get_sync_status() == SNTP_SYNC_STATUS_RESET && ++retry < retry_count) {
  161.         printf("Waiting for system time to sync... (%d/%d)\n", retry, retry_count);
  162.         vTaskDelay(2000 / portTICK_PERIOD_MS);
  163.     }
  164.     xTaskCreate(&http_task, "http_task", 18192, NULL, 5, NULL);
  165. }
复制代码
终端打印接收结果，可以成功等待接受长文本
8.png

NTP服务器

NTP服务器（Network Time Protocol Server）的作用是提供精确、统一的时间同步服务，它是互联网中时间同步的核心基础设施。以下是其核心作用：
1. 时间同步


  • 核心功能：NTP服务器通过协议将设备（如计算机、手机、物联网设备）的本地时间与全球标准时间（如UTC）同步。
  • 解决设备时钟漂移：硬件时钟可能因温度、电池等原因产生误差，NTP定期校准时间，确保设备间时间一致。
2. 安全协议的基础


  • SSL/TLS证书验证：HTTPS通信依赖证书的有效期验证。若设备时间错误：

    • 证书可能被误判为“未生效”或“已过期”，导致连接失败。

  • 示例场景：你之前的ESP32代码中，若系统时间未同步，访问HTTPS API时可能因证书时间校验失败而超时。
3. 日志与调试


  • 统一时间戳：设备生成的日志若时间不一致，将难以追踪问题（如分布式系统故障）。
  • 示例：ESP32的日志若时间错误，无法与服务器日志对照，增加调试难度。
4. 协调分布式系统


  • 跨设备协同：物联网、金融交易等场景依赖毫秒级时间同步，避免数据冲突。
  • 示例：多个ESP32设备协同工作时，需严格按时间顺序执行操作。
5. NTP与SNTP的区别


  • NTP：高精度（毫秒/微秒级），适用于服务器、基站等。
  • SNTP（简单NTP）：精简版，精度稍低（秒级），适合资源受限设备（如ESP32）。
  • 你的代码：使用esp_sntp_init()即是为ESP32提供轻量级时间同步。
为什么你的ESP32项目需要NTP服务器？

在之前的代码中，你遇到HTTP连接超时问题，可能原因之一是：

  • ESP32系统时间未同步 → SSL证书验证失败 → 服务器拒绝连接。
  • 初始化SNTP后，设备获取正确时间 → 证书验证通过 → 正常通信。
总结

NTP服务器像互联网的“原子钟”，确保设备时间精准统一。对物联网设备而言，它是安全通信、协同工作的基石。
如果文章对你有所帮助，可以帮我点一下左下角推荐该文，万分感谢
博主目前在广州，深圳找实习。
如有大佬（HR,BOSS）能推荐实习，恳请私信小弟，给个机会，帮帮小弟，万分感谢！！！

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
ESP32S3接入大模型API

使用道具 举报

相关推荐
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册
发帖
跑两獗
2025-6-3 10:42:32

0

粉丝关注

12

主题发布

板块介绍填写区域，请于后台编辑
微信扫一扫