Dify系统中历史对话数据的定时归档与压缩存储方案-人工智能-PHP中文网

归档任务每周一凌晨2点自动执行，将30天前会话压缩为csv.gz存至/opt/dify/archives/，校验通过后软删除archived=true且created_at

☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜

dify系统中历史对话数据的定时归档与压缩存储方案

你需要在Dify系统中自动将历史对话数据从热存储迁出、归档为压缩文本并长期保存，避免数据库膨胀又保留审计与回溯能力。

确认归档数据源与范围

进入 Dify 后台管理界面 → 点击「数据管理」→ 选择「会话历史」标签页。确认当前部署使用的是 PostgreSQL 数据库（自托管版），且表 conversation_messages 中已存在超过 30 天的旧记录。

【必须验证】 执行 SQL 查询：SELECT COUNT(*) FROM conversation_messages WHERE created_at 若返回结果为 0，则暂停后续操作——没有可归档数据，强行执行将生成空压缩包。

配置定时归档任务（Cron + Python 脚本）

方法一：基于系统级 Cron 的轻量归档

在服务器上创建归档脚本 /opt/dify/scripts/archive_conversations.py，内容如下：

```python
import psycopg2
import gzip
import csv
from datetime import datetime, timedelta
from pathlib import Path

conn = psycopg2.connect(
    host="localhost",
    database="dify",
    user="dify-user",
    password="your-db-pass"
)
cur = conn.cursor()

cutoff = (datetime.utcnow() - timedelta(days=30)).isoformat()
cur.execute("""
    SELECT c.id as conv_id, m.role, m.content, m.created_at
    FROM conversation_messages m
    JOIN conversations c ON m.conversation_id = c.id
    WHERE m.created_at     ORDER BY m.created_at
""", (cutoff,))

rows = cur.fetchall()
if not rows:
    exit(0)

archive_path = f"/opt/dify/archives/conversations_{datetime.now().strftime('%Y%m%d_%H%M%S')}.csv.gz"
Path(archive_path).parent.mkdir(exist_ok=True)

with gzip.open(archive_path, "wt", encoding="utf-8") as f:
    writer = csv.writer(f)
    writer.writerow(["conv_id", "role", "content", "created_at"])
    for r in rows:
        writer.writerow(r)

# 归档后标记为已处理（非删除）
cur.execute("UPDATE conversation_messages SET archived = true WHERE created_at conn.commit()
```