登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  科技周边 >  人工智能

如何用Supabase存DeepSeek V4微信用户数据_后端搭建【后端】

时间:2026-05-03 17:02:37 211浏览 收藏

今天golang学习网给大家带来了《如何用Supabase存DeepSeek V4微信用户数据_后端搭建【后端】》,其中涉及到的知识点包括等等,无论你是小白还是老手,都适合看一看哦~有好的建议也欢迎大家在评论留言,若是看完有所收获,也希望大家能多多点赞支持呀!一起加油学习~

可借助Supabase的PostgreSQL实例实现微信生态中DeepSeek V4用户会话与身份信息的安全持久化存储,具体路径包括:一、创建Supabase项目并启用带RLS策略的PostgreSQL;二、通过微信网页授权绑定openid至Supabase auth.users;三、部署后端服务接收微信事件并写入wechat_users及wechat_sessions表;四、基于openid配置RLS确保数据隔离;五、在DeepSeek V4响应后异步写入会话记录。

如何用Supabase存DeepSeek V4微信用户数据_后端搭建【后端】

如果您在将DeepSeek V4接入微信生态后,需持久化存储用户会话、对话历史或身份信息,但现有数据库缺乏结构化、实时同步与鉴权能力,则可借助Supabase的PostgreSQL实例实现安全、可扩展的数据落库。以下是完成该目标的具体实施路径:

一、创建Supabase项目并启用PostgreSQL

Supabase提供托管式PostgreSQL服务,支持Row Level Security(RLS)策略与实时订阅,适配微信用户数据的隐私隔离与高并发写入需求。需确保项目已开通云原生数据仓库AnalyticDB PostgreSQL版且地域支持Authentication模块。

1、访问Supabase Dashboard,点击“New project”新建项目。

2、填写项目名称,选择地域(中国地域须为2025年09月04日后创建),设置数据库密码。

3、等待初始化完成,在左侧导航栏确认存在Table EditorAuthentication菜单项。

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_userswechat_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

终于介绍完啦!小伙伴们,这篇关于《如何用Supabase存DeepSeek V4微信用户数据_后端搭建【后端】》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布科技周边相关知识,快来关注吧!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>