通过云上数据库三步构建RAG系统

2024-07-09 20654

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 本文介绍了如何使用OpenSearch LLM智能问答版通过云上数据库一站式构建RAG系统。

随着AIGC技术日新月异的发展，LLM应用也在持续迭代，检索增强生成（RAG）系统已经成为企业知识库、智能客服、电商导购等场景的核心环节。阿里云OpenSearch LLM智能问答版联合数据集成Data Integration产品，帮助企业和开发者实现分钟级构建专属RAG系统。本教程介绍如何通过云上数据库一站式构建RAG系统。

方案概览

OpenSearch-LLM智能问答版：OpenSearch LLM智能问答版内置数据解析与处理、切片、向量化、文本&向量检索、多模态LLM等模型和功能，提供一站式开箱即用的RAG产品，快速构建包含问答、对话、文档链接、参考图片在内的多模态对话式搜索服务，帮助企业和开发者快速搭建专属RAG系统。
数据集成 Data Integration：数据集成 Data Integration是阿里云对外提供的安全、低成本、稳定高效、弹性伸缩的数据同步平台，属于DataWorks的核心能力之一，致力于提供复杂网络环境下、丰富的异构数据源之间高速稳定的数据移动及同步能力。

通过云上数据库一站式构建RAG系统，只需3步：

创建实例：我们首先分别创建OpenSearch-LLM智能问答版实例以及数据集成Data Integration实例。
配置数据同步任务：然后我们在数据集成控制台配置数据同步任务，将数据源数据同步到OpenSearch。
问答测试：最后我们登录OpenSearch-LLM智能问答版控制台对这个RAG系统进行问答效果测试。

创建实例

购买OpenSearch-LLM智能问答版实例：进入OpenSearch LLM智能问答版售卖页，按需求购买实例。
购买数据集成Data Integration实例：进入数据集成Data Integration售卖页，按需求购买实例，可选择独享资源或通用资源。

请务必保证OpenSearch-LLM智能问答版实例和数据集成Data Integration实例在同一地域。

登录DataWorks控制台，创建DataWorks工作空间，并将已购买的资源组绑定至当前工作空间。
单击创建工作空间按钮：

进行资源组配置：

配置数据同步任务

在DataWorks工作空间列表界面，选择操作栏下选择快速进入->数据集成进入数据集成控制台，在创建同步任务中选择来源和去向后单击开始创建。

来源选择当前数据存储的云上数据库（本文以Elasticsearch为例）。
去向选择OpenSearch。

设置新任务名称，同步类型选择单表离线，然后跳转到Datastudio进行配置。

新建节点，节点类型选择离线同步，按需选择节点路径并点击确认。
选择数据源、数据集成资源组。
按页面要求填写云上数据源，并完成连通性测试（如果未连通则按页面配置完成相应参数调整）。
单击下一步，完成数据去向配置。
Elasticsearch数据源同步OpenSearch实例参考配置代码：

{
    "transform": false,
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "elasticsearch",
            "parameter": {
                "search": {
                    "match": {
                        "_type": "_doc"   //Elasticsearch中的数据查询条件
                    }
                },
                "datasource": "test",   //DataWorks中配置的数据源名称
                "retryCount": 30,
                "readTimeOut": "600000",
                "scroll": "1m",
                "column": [   //需要同步至OpenSearch中的原始字段，建议包含id、标题、内容等RAG系统常用字段
                    "id",
                    "title",
                    "content"
                ],
                "index": "main",    //OpenSearch中的表名，如果同步至主表则为main
                "pageSize": "100",
                "type": "default",
                "connTimeOut": "600000",
                "retrySleepTime": "10000"
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "opensearch",
            "parameter": {
                "accessId": "",   //云账号accessId
                "endpoint": "http://opensearch.cn-shanghai.aliyuncs.com",   //OpenSearch上海区域Endpoint
                "accessKey": "",    //云账号accessKey
                "indexName": "data_es",   //OpenSearch实例名称
                "host": "http://opensearch-cn-shanghai.aliyuncs.com",   //OpenSearch上海区域host
                "column": [   //同步至OpenSearch的目标字段，OpenSearch主表结构可参考控制台或产品文档
                    "id",
                    "title",
                    "content"
                ],
                "writeMode": "add",
                "batchSize": "10",
                "skipDirtyRecord": "true",
                "ignoreWriteError": "false",
                "table": "main"
            },
            "name": "Writer",
            "category": "writer"
        },
        {
            "copies": 1,
            "parameter": {
                "nodes": [],
                "edges": [],
                "groups": [],
                "version": "2.0"
            },
            "name": "Processor",
            "category": "processor"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "locale": "zh",
        "speed": {
            "throttle": false,
            "concurrent": 2
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}