使用 Dify 和 Twilio 构建 WhatsApp 机器人

作者：Warren， Microsoft 最有價值專家 (MVP)

1. 概述

随着世界通过消息应用程序变得越来越紧密地连接在一起，聊天机器人已成为企业与客户进行更个人化交流的关键工具。

随着人工智能的崛起，聊天机器人变得更聪明，更个性化，更直观。在本文中，我们将向你展示如何使用使用Dify和Twilio将其与WhatsApp集成。

你将首先使用FastAPI 接入Dify设置后端，然后，你将集成Twilio的WhatsApp消息API，允许客户与你的WhatsApp聊天机器人开始对话。

使用Localtunnel，将FastAPI本地主机放在互联网上，使其可以供Twilio API通信。

2. 準備工作

安裝好Docker 和Docker Compose
Twilio帐户：在這裡創建一個免費Twilio帳戶
一部安装了WhatsApp的智能手机，用于测试你的AI聊天机器人
对FastAPI的基本理解，这是一个使用Python 3.6+构建API的框架

3. 创建Dify基础编排聊天助手应用（節錄自手摸手教你把 Dify 接入微信生态)

首先，登录Dify官方应用平台，你可以选择使用Github登录或者使用Google登录。此外，你也可以参考Dify官方教程Docker Compose 部署 | 中文 | Dify 私有部署，Dify是开源项目，支持私有部署。

登录成功后，进入Dify页面，我们按照下方步骤创建一个基础编排聊天助手应用

点击页面上方的工作室
创建空白应用
应用类型选择聊天助手
聊天助手编排方式选择基础编排
选择应用图标并为应用填写一个名称，比如基础编排聊天助手
点击创建

创建成功后我们会跳转到上图所示页面，我们继续配置应用

选择模型，如gpt-3.5-turbo-0125
设置模型参数
填写应用提示词

在配置完成后，我们可以在右侧对话框进行测试，在测试完成后，进行如下操作

发布
更新
访问API

（4）生成基础编排聊天助手API密钥

在点击"访问API"后，我们会跳转到上图的API管理页面，在这个页面我们按照如下步骤获取API密钥：

点击右上角API密钥
点击创建密钥
复制保存密钥

在保存密钥后，还需要查看右上角的API服务器，如果是Dify官网的应用，API服务器地址为 "https://api.dify.ai/v1", 如果是私有部署的，请确认你自己的API服务器地址。

至此，创建聊天助手的准备工作结束，在此小节中我们只需要保存好两个东西：API密钥与API服务器地址

4. 獲取Twilio密钥

转到[Twilio控制台] 畫面應該會直接獲取到Account SID 和Auth Token，保存好這两个东西。

5. 创建你的聊天机器人

在这一部分，你将使用FastAPI和Twilio编写一个基本的聊天机器人的代码。

5.1 下載代碼

git clone https://github.com/somethingwentwell/dify-twilio-whatsapp

5.2 配置.env

在项目根目录创建.env，內容如下:

TWILIO_NUMBER=+14155238886
TWILIO_ACCOUNT_SID=<在(4)獲取的Twilio Account SID>
TWILIO_AUTH_TOKEN=<在(4)獲取的Twilio Auth Token>
DIFY_URL=<在(3)獲取的Dify API服务器地址>
DIFY_API_KEY=<在(3)獲取的Dify API密钥>

5.3 運行代码

執行docker compose up

docker compose up

如果运行成功，你应该会看到

dify-whatsapp-1  | INFO:     Started server process [68]
dify-whatsapp-1  | INFO:     Waiting for application startup.
dify-whatsapp-1  | INFO:     Application startup complete.

在浏览器中打开 http://localhost:9000。你应该看到的结果是一个JSON响应，内容为 {"msg": "working"}。

5.4 使用Localtunnel 將本地项目放到公网访问

Twilio需要向你的后端发送消息，你需要在公共服务器上托管你的应用。一个简单的方法是使用localtunnel。

让FastAPI应用继续在9000端口运行，并在另一个终端窗口运行以下localtunnel命令：

npx localtunnel --port 9000

上述命令在你的本地服务器（运行在9000端口）和localtunnel创建的公共域之间建立了一个连接。一旦你有了localtunnel转发URL，任何来自客户端对该URL的请求都会自动被定向到你的FastAPI后端。

5.5 代码解释

5.5.1 检查该号码是否已在白名单中，不在白名单的用户直接返回“你未注册此服务。”

enrolled_numbers = ['+14155238886']

对应

    # Check if the number is enrolled
    if whatsapp_number not in enrolled_numbers:
        message = client.messages.create(  
            from_=f"whatsapp:{twilio_number}",  
            body="You are not enrolled in this service.",  
            to=f"whatsapp:{whatsapp_number}"  
        )
        return ""

5.5.2 将WhatsApp号码作为Dify会话ID，确保用户持续保持该会话

conversation_ids = {}

对应

    url = dify_url
    headers = {  
        'Content-Type': 'application/json',  
        'Authorization': f"Bearer {dify_api_key}",  
    }  
    data = {  
        'inputs': {},  
        'query': Body,  
        'response_mode': 'streaming',  
        'conversation_id': conversation_ids.get(whatsapp_number, ''),  
        'user': whatsapp_number,  
    }  
    response = requests.post(url, headers=headers, data=json.dumps(data), stream=True)  
    answer = []  
    for line in response.iter_lines():  
        if line:  
            decoded_line = line.decode('utf-8')  
            if decoded_line.startswith('data: '):  
                decoded_line = decoded_line[6:]  
            try:  
                json_line = json.loads(decoded_line) 
                if "conversation_id" in json_line:
                    conversation_ids[whatsapp_number] = json_line["conversation_id"]
                if json_line["event"] == "agent_thought":  
                    answer.append(json_line["thought"])  
            except json.JSONDecodeError: 
                print(json_line)  
                continue  

    merged_answer = ''.join(answer)