如何通过Supabase后端搭建实现DeepSeek V4微信用户数据存储？
- 内容介绍
- 文章标签
- 相关推荐
本文共计1250个文字，预计阅读时间需要5分钟。
如果您要将以下内容进行简化改写，请提供原始内容，我将根据您的要求进行改写。
一、创建Supabase项目并启用PostgreSQL
Supabase提供托管式PostgreSQL服务，支持Row Level Security（RLS）策略与实时订阅，适配微信用户数据的隐私隔离与高并发写入需求。需确保项目已开通云原生数据仓库AnalyticDB PostgreSQL版且地域支持Authentication模块。
1、访问Supabase Dashboard，点击“New project”新建项目。
2、填写项目名称，选择地域（中国地域须为2025年09月04日后创建），设置数据库密码。
3、等待初始化完成，在左侧导航栏确认存在Table Editor与Authentication菜单项。
4、进入Database → SQL Editor，执行建表语句：
CREATE TABLE wechat_users ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), openid TEXT UNIQUE NOT NULL, nickname TEXT, avatar_url TEXT, gender SMALLINT, city TEXT, province TEXT, country TEXT, subscribe_time TIMESTAMPTZ, created_at TIMESTAMPTZ DEFAULT NOW(), updated_at TIMESTAMPTZ DEFAULT NOW() );
5、执行以下命令启用RLS并设置默认策略：
ALTER TABLE wechat_users ENABLE ROW LEVEL SECURITY; CREATE POLICY "Users can view own data" ON wechat_users FOR SELECT USING (auth.uid() = id);
二、配置微信OAuth回调与用户标识绑定
微信不直接提供标准OAuth 2.0授权码流程，需通过公众号网页授权获取用户openid与基础信息，再将其映射至Supabase auth.users表，实现统一身份管理。
1、登录微信公众平台，进入「开发 → 接口权限 → 网页服务 → 网页授权获取用户基本信息」，配置授权回调域名（须为Supabase项目域名或反向代理域名）。
2、在Supabase Dashboard中，进入Authentication → Providers，关闭所有第三方Provider（如GitHub、Google），因微信非标准OIDC提供方，需自定义集成。
3、在SQL Editor中插入自定义登录函数：
CREATE OR REPLACE FUNCTION public.upsert_wechat_user(openid TEXT, nickname TEXT, avatar TEXT) RETURNS auth.users AS $$ DECLARE new_user auth.users%ROWTYPE; BEGIN INSERT INTO auth.users (email, email_confirmed_at, encrypted_password, raw_app_meta_data, raw_user_meta_data, aud, role) VALUES (concat(openid, '@wechat'), NOW(), '', jsonb_build_object('provider', 'wechat'), jsonb_build_object('nickname', nickname, 'avatar_url', avatar), 'authenticated', 'authenticated') ON CONFLICT (email) DO UPDATE SET raw_user_meta_data = EXCLUDED.raw_user_meta_data, updated_at = NOW() RETURNING * INTO new_user; RETURN new_user; END; $$ LANGUAGE plpgsql SECURITY DEFINER;
三、部署后端服务接收微信事件并写入Supabase
需部署一个轻量Web服务，用于接收微信服务器推送的事件（如关注、扫码、消息），解析后调用Supabase REST API或pgClient写入wechat_users表及自定义会话表。推荐使用Node.js + Express + @supabase/supabase-js。
1、初始化Supabase客户端，使用Project URL与anon密钥（禁止使用service_role密钥）：
const { createClient } = require('@supabase/supabase-js'); const supabase = createClient('https://xxx.supabase.co', 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...');
2、编写微信事件处理路由，示例处理关注事件：
app.post('/wechat', async (req, res) => { const xml = await req.text(); const parsed = parseXML(xml); if (parsed.MsgType === 'event' && parsed.Event === 'subscribe') { const { FromUserName: openid, NickName: nickname, HeadImgUrl: avatar } = parsed; await supabase.from('wechat_users').upsert({ openid, nickname, avatar_url: avatar }).eq('openid', openid); } res.status(200).send('success'); });
3、在Supabase中创建wechat_sessions表用于存储DeepSeek V4交互记录：
CREATE TABLE wechat_sessions ( id SERIAL PRIMARY KEY, openid TEXT NOT NULL REFERENCES wechat_users(openid), session_id TEXT NOT NULL, input_text TEXT, output_text TEXT, model_version TEXT DEFAULT 'deepseek-v4', created_at TIMESTAMPTZ DEFAULT NOW() );
四、使用Row Level Security控制数据可见性
为防止不同微信用户数据越权访问，必须对wechat_users和wechat_sessions启用RLS，并基于openid字段建立行级过滤策略，确保每个请求仅能操作自身关联数据。
1、为wechat_sessions启用RLS：
ALTER TABLE wechat_sessions ENABLE ROW LEVEL SECURITY;
2、创建策略，允许用户仅查询/插入自身openid对应记录：
CREATE POLICY "Users can manage own sessions" ON wechat_sessions FOR ALL USING (openid = current_setting('request.jwt.claims', true)::json->>'openid') WITH CHECK (openid = current_setting('request.jwt.claims', true)::json->>'openid');
3、在Supabase Dashboard中进入Authentication → URL Configuration，设置Site URL为您的业务域名（如https://yourapp.com），确保JWT claims中可注入openid。
五、配置Webhook自动同步DeepSeek V4响应结果
当DeepSeek V4模型返回推理结果后，需将原始输入、输出、上下文元数据写入Supabase，供后续分析或重放调试。此过程应脱离微信消息主链路，采用异步队列或直接HTTP POST。
1、在调用DeepSeek V4 API的后端逻辑中，添加响应后置处理：
const response = await fetch('https://api.deepseek.com/v1/chat/completions', { method: 'POST', headers: { 'Authorization': `Bearer ${DEEPSEEK_KEY}`, 'Content-Type': 'application/json' }, body: JSON.stringify(payload) }); const result = await response.json(); const { content } = result.choices[0].message; await supabase.from('wechat_sessions').insert({ openid: payload.user_openid, session_id: payload.session_id, input_text: payload.messages[0].content, output_text: content, model_version: 'deepseek-v4' });
2、若使用云函数（如Vercel Edge Function），需在函数头部显式设置Supabase anon密钥与URL环境变量。
3、验证写入：进入SupabaseTable Editor，切换至wechat_sessions表，确认新记录按openid正确分区且model_version字段值为deepseek-v4。
本文共计1250个文字，预计阅读时间需要5分钟。
如果您要将以下内容进行简化改写，请提供原始内容，我将根据您的要求进行改写。
一、创建Supabase项目并启用PostgreSQL
Supabase提供托管式PostgreSQL服务，支持Row Level Security（RLS）策略与实时订阅，适配微信用户数据的隐私隔离与高并发写入需求。需确保项目已开通云原生数据仓库AnalyticDB PostgreSQL版且地域支持Authentication模块。
1、访问Supabase Dashboard，点击“New project”新建项目。
2、填写项目名称，选择地域（中国地域须为2025年09月04日后创建），设置数据库密码。
3、等待初始化完成，在左侧导航栏确认存在Table Editor与Authentication菜单项。
4、进入Database → SQL Editor，执行建表语句：
CREATE TABLE wechat_users ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), openid TEXT UNIQUE NOT NULL, nickname TEXT, avatar_url TEXT, gender SMALLINT, city TEXT, province TEXT, country TEXT, subscribe_time TIMESTAMPTZ, created_at TIMESTAMPTZ DEFAULT NOW(), updated_at TIMESTAMPTZ DEFAULT NOW() );
5、执行以下命令启用RLS并设置默认策略：
ALTER TABLE wechat_users ENABLE ROW LEVEL SECURITY; CREATE POLICY "Users can view own data" ON wechat_users FOR SELECT USING (auth.uid() = id);
二、配置微信OAuth回调与用户标识绑定
微信不直接提供标准OAuth 2.0授权码流程，需通过公众号网页授权获取用户openid与基础信息，再将其映射至Supabase auth.users表，实现统一身份管理。
1、登录微信公众平台，进入「开发 → 接口权限 → 网页服务 → 网页授权获取用户基本信息」，配置授权回调域名（须为Supabase项目域名或反向代理域名）。
2、在Supabase Dashboard中，进入Authentication → Providers，关闭所有第三方Provider（如GitHub、Google），因微信非标准OIDC提供方，需自定义集成。
3、在SQL Editor中插入自定义登录函数：
CREATE OR REPLACE FUNCTION public.upsert_wechat_user(openid TEXT, nickname TEXT, avatar TEXT) RETURNS auth.users AS $$ DECLARE new_user auth.users%ROWTYPE; BEGIN INSERT INTO auth.users (email, email_confirmed_at, encrypted_password, raw_app_meta_data, raw_user_meta_data, aud, role) VALUES (concat(openid, '@wechat'), NOW(), '', jsonb_build_object('provider', 'wechat'), jsonb_build_object('nickname', nickname, 'avatar_url', avatar), 'authenticated', 'authenticated') ON CONFLICT (email) DO UPDATE SET raw_user_meta_data = EXCLUDED.raw_user_meta_data, updated_at = NOW() RETURNING * INTO new_user; RETURN new_user; END; $$ LANGUAGE plpgsql SECURITY DEFINER;
三、部署后端服务接收微信事件并写入Supabase
需部署一个轻量Web服务，用于接收微信服务器推送的事件（如关注、扫码、消息），解析后调用Supabase REST API或pgClient写入wechat_users表及自定义会话表。推荐使用Node.js + Express + @supabase/supabase-js。
1、初始化Supabase客户端，使用Project URL与anon密钥（禁止使用service_role密钥）：
const { createClient } = require('@supabase/supabase-js'); const supabase = createClient('https://xxx.supabase.co', 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...');
2、编写微信事件处理路由，示例处理关注事件：
app.post('/wechat', async (req, res) => { const xml = await req.text(); const parsed = parseXML(xml); if (parsed.MsgType === 'event' && parsed.Event === 'subscribe') { const { FromUserName: openid, NickName: nickname, HeadImgUrl: avatar } = parsed; await supabase.from('wechat_users').upsert({ openid, nickname, avatar_url: avatar }).eq('openid', openid); } res.status(200).send('success'); });
3、在Supabase中创建wechat_sessions表用于存储DeepSeek V4交互记录：
CREATE TABLE wechat_sessions ( id SERIAL PRIMARY KEY, openid TEXT NOT NULL REFERENCES wechat_users(openid), session_id TEXT NOT NULL, input_text TEXT, output_text TEXT, model_version TEXT DEFAULT 'deepseek-v4', created_at TIMESTAMPTZ DEFAULT NOW() );
四、使用Row Level Security控制数据可见性
为防止不同微信用户数据越权访问，必须对wechat_users和wechat_sessions启用RLS，并基于openid字段建立行级过滤策略，确保每个请求仅能操作自身关联数据。
1、为wechat_sessions启用RLS：
ALTER TABLE wechat_sessions ENABLE ROW LEVEL SECURITY;
2、创建策略，允许用户仅查询/插入自身openid对应记录：
CREATE POLICY "Users can manage own sessions" ON wechat_sessions FOR ALL USING (openid = current_setting('request.jwt.claims', true)::json->>'openid') WITH CHECK (openid = current_setting('request.jwt.claims', true)::json->>'openid');
3、在Supabase Dashboard中进入Authentication → URL Configuration，设置Site URL为您的业务域名（如https://yourapp.com），确保JWT claims中可注入openid。
五、配置Webhook自动同步DeepSeek V4响应结果
当DeepSeek V4模型返回推理结果后，需将原始输入、输出、上下文元数据写入Supabase，供后续分析或重放调试。此过程应脱离微信消息主链路，采用异步队列或直接HTTP POST。
1、在调用DeepSeek V4 API的后端逻辑中，添加响应后置处理：
const response = await fetch('https://api.deepseek.com/v1/chat/completions', { method: 'POST', headers: { 'Authorization': `Bearer ${DEEPSEEK_KEY}`, 'Content-Type': 'application/json' }, body: JSON.stringify(payload) }); const result = await response.json(); const { content } = result.choices[0].message; await supabase.from('wechat_sessions').insert({ openid: payload.user_openid, session_id: payload.session_id, input_text: payload.messages[0].content, output_text: content, model_version: 'deepseek-v4' });
2、若使用云函数（如Vercel Edge Function），需在函数头部显式设置Supabase anon密钥与URL环境变量。
3、验证写入：进入SupabaseTable Editor，切换至wechat_sessions表，确认新记录按openid正确分区且model_version字段值为deepseek-v4。