报时机器人源码参考[1][2]，本文重点介绍当 tracker_store 类型为 SQL 时，events 表的表结构以及数据是如何生成的。以及当 event_broker 类型为 SQL 时，events 表的表结构以及数据是如何生成的。

一.报时机器人启动 [3]

  Rasa 对话系统启动方式详见参考文献[3]中执行程序部分，这里不再赘述。如下所示：

1.加载模型：rasa run --cors "*"

2.运行 action server：rasa run actions

3.运行 Web 页面：python -m http.server 8080

二.(tracker_store)endpoints.yml 和 events 表结构

  使用 mysql 数据库来存储对话，使用 MySQL 新建 db 为 rasa_tracker_store，其中字符集和排序规则分别为 utf8mb4 -- UTF-8 Unicode 和 utf8mb4_0900_ai_ci。

1.endpoints.yml 配置文件

tracker_store:
    type: SQL
    dialect: "mysql+pymysql"
    url: "localhost"  # your mysql host
    db: "rasa_tracker_store"  # name of the mysql database
    username: "root"  # username to access the database
    password: "root"  # password to access the database

2.新建数据库 rasa_tracker_store

3.events 表结构

（1）id：主键 id

（2）sender_id：发送者 id

（3）type_name：event 的类型名字

（4）timestamp：时间戳

（5）intent_name：意图名字

（6）action_name：action 名字

（7）data：数据

4.events 表数据内容

  以用户问："今天星期几"，机器答："星期三"为例子展开介绍。

  生成的 rasa_tracker_store.events 数据表内容，如下所示：

（1）id：主键 id。

  这个自增主键就不用多说了。

（2）sender_id：发送者 id。

  比如，oCMNVZ44YCbHIcFYAAAB。这个数据是如何来的？生成的规则是什么呢？

sender_id 是在 SQLTrackerStore 类中的 SQLEvent 子类中初始化的。SQLEvent 子类是 SQLAlchemy 的一部分，用于在数据库中创建一个表。在这个表中，sender_id 是一个字段，它的类型是字符串（最大长度为 255），并且它被设置为非空（nullable=False），并且为其创建了索引（index=True）。这意味着在数据库中，sender_id 字段不能为 null，并且可以被快速查找。

  sender_id 是在创建 DialogueStateTracker 对象时传入的一个参数，它通常用于标识对话的发送者。在 Rasa 中，每个对话都有一个唯一的 sender_id，这样可以区分不同的用户会话。在 from_events 类方法中，sender_id 是作为第一个参数传入的。这个方法用于从一系列事件中创建一个 DialogueStateTracker 对象。这些事件会被应用到新的跟踪器上，以重建其状态。生成 sender_id 的具体规则取决于你的应用，当客户端是 Rasa Shell、Rasa X、HTTP API 等的时候，都不相同。由于本次使用的是 Socket 方式，可以顺藤摸瓜去找 sender_id 的具体生成规则，这里不再细节展开。rasa/core/channels/socketio.py 如下所示：

（3）type_name：event 的类型名字。

  比如，action、session_started、user、slot、user_featurization、bot。这个数据是什么？除了这个数据还有其它的类型名字吗？（列出全部）。rasa/shared/core/events.py 如下所示：

（4）timestamp：Unix 时间戳。

  比如，1704300000，转换后的日期时间：2024-01-03 16:40:00。Unix 时间戳是指从 1970 年 1 月 1 日 00:00:00UTC（协调世界时）开始的秒数。

from datetime import datetime

timestamp = 1704300000
date_object = datetime.utcfromtimestamp(timestamp)

print("转换后的日期时间：", date_object)

（5）intent_name：意图名字

  比如，query_weekday。报时机器人总共的意图包括 greet、goodbye、query_time、query_date、query_weekday。对应的例子如下所示：

version: "3.0"
nlu:
  - intent: greet
    examples: |
      - 你好
      - 您好
      - hello
      - hi
      - 喂
      - 在么
  - intent: goodbye
    examples: |
      - 拜拜
      - 再见
      - 拜
      - 退出
      - 结束
  - intent: query_time
    examples: |
      - 现在几点了
      - 什么时候了
      - 几点了
      - 现在什么时候了
      - 现在的时间
  - intent: query_date
    examples: |
      - [今天](date)几号
      - [今天](date)是几号
      - [昨天](date)几号
      - [明天](date)几号
      - [今天](date)的日期
      - [今天](date)几号了
      - [明天](date)的日期
      - 几号
  - intent: query_weekday
    examples: |
      - [今天](date)星期几
      - [明天](date)星期几
      - [昨天](date)星期几
      - [今天](date)是星期几
      - 星期几

（6）action_name：action 名字

  比如，action_session_start（会话开始）、action_listen（机器人处于监听状态，机器人每次回答完毕后都会处于监听状态）、date（日期实体）、action_query_weekday（自定义 action）。除此之外，还有哪些 action_name 呢？（列出全部）。rasa/core/actions/action.py 如下所示：

（7）data：数据

  取出一条 data 数据字段进行 json 显示，如下所示：

{
        "event": "action",
        "timestamp": 1704297163.3703225,
        "metadata": {
                "model_id": "4ca8c86f1301497f9488c47c860f39fd",
                "assistant_id": "20240103-232935-excited-category"
        },
        "name": "action_session_start",
        "policy": null,
        "confidence": 1.0,
        "action_text": null,
        "hide_rule_turn": false
}

• event：事件的名字。（列出全部）
• timestamp：时间戳。
• metadata-model_id：模型 id。这个并不是模型的名字，比如训练的报时机器人模型为 20240103-233232-windy-borzoi.tar.gz。
• metadata-assistant_id：这个是 config.yml 文件中定义的 assistant_id: 20240103-232935-excited-category。
• name：action 的名字。
• policy：使用的策略。
• confidence：置信度。
• action_text：动作文本，即端到端机器人响应的文本。
• hide_rule_turn：是否隐藏规则回合。

  上述字段大都来自于 ACTION_EXECUTED（rasa/shared/utils/schemas/events.py），ACTION_EXECUTED 是一个字典，它定义了 Rasa 中 "action" 事件的 JSON schema。这个 schema 描述了 "action" 事件的数据结构，包括它的属性和这些属性的类型。如下所示：

ACTION_EXECUTED = {
    "properties": {
        "event": {"const": "action"},
        "policy": {"type": ["string", "null"]},
        "confidence": {"type": ["number", "null"]},
        "name": {"type": ["string", "null"]},
        "hide_rule_turn": {"type": "boolean"},
        "action_text": {"type": ["string", "null"]},
    }
}

  在 ACTION_EXECUTED schema 中，相关属性解释如下所示：

• event: 这是一个常量，值为 "action"，表示这是一个 "action" 事件。
• policy: 这是一个字符串，表示执行这个动作的策略的名称。它也可以为 null。
• confidence: 这是一个数字，表示执行这个动作的策略的置信度。它也可以为 null。
• name: 这是一个字符串，表示执行的动作的名称。它也可以为 null。
• hide_rule_turn: 这是一个布尔值，表示是否隐藏规则回合。
• action_text: 这是一个字符串，表示动作的文本。它也可以为 null。

  这个 schema 用于验证 "action" 事件的数据是否符合预期的格式。如果一个 "action" 事件的数据不符合这个 schema，那么在处理这个事件时，Rasa 将会抛出一个错误。

5.action 和 event 间的关系

  在 Rasa 中，动作（action）和事件（event）是两个不同但相关的概念。如下所示：

（1）action

  动作是在对话中执行的一些操作，例如向用户发送消息、调用外部服务、或者进行自定义的计算。在 Rasa 中，动作通常与对话策略相关联，用于决定在特定的对话状态下应该执行哪个动作。动作由自定义的动作类或内置的动作类实现，它们被定义为继承自 Action 类。

（2）event

  事件是对话中的状态更改的表示，例如用户的输入、机器人的响应、槽位的更新等。在 Rasa 中，对话的历史记录是一系列事件的集合。事件被用于跟踪对话的状态，对话管理器使用事件来更新对话状态。不同的事件类型表示不同的对话动作和状态变化。

（3）两者关系

• 当动作执行时，通常会生成一个或多个事件，这些事件描述了对话状态的变化。
• 每个对话轮次中都会有一系列事件，包括用户的输入事件（例如 UserUttered）、动作执行事件（例如 ActionExecuted）、槽位更新事件（例如 SlotSet）、机器人响应事件（例如 BotUttered）等。

  在对话中，动作和事件密切相互关联。动作执行时会触发事件，这些事件进而影响对话状态的演进。一般来说，对话的历史记录中的事件序列描述了对话的全貌，对话管理器利用这些事件来进行决策。

三.(event_broker)endpoints.yml 和 events 表结构

1.endpoints.yml 配置文件

  使用 mysql 数据库来消息队列，如下所示：

event_broker:
  type: SQL
  url: "localhost"
  port: 3306
  dialect: "mysql+pymysql"
  username: "root"
  password: "root"
  db: "rasa_event_broker"

2.新建数据库 rasa_tracker_store

  创建数据库方式与 rasa_tracker_store 相同，这里不再赘述。

3.events 表结构

  生成的 rasa_event_broker.events 数据表内容，如下所示：

（1）id：主键 id

（2）sender_id：发送者 id

（3）data：数据

4.events 表数据内容

  取出一条 data 数据字段进行 json 显示，如下所示：

{
        "sender_id": "oCMNVZ44YCbHIcFYAAAB",
        "event": "action",
        "timestamp": 1704297163.3703225,
        "metadata": {
                "model_id": "4ca8c86f1301497f9488c47c860f39fd",
                "assistant_id": "20240103-232935-excited-category"
        },
        "name": "action_session_start",
        "policy": null,
        "confidence": 1.0,
        "action_text": null,
        "hide_rule_turn": false
}

  发现 event_broker.events.data 和 tracker_store.events.data 相比，除了多一个 sender_id 字段，其它的都是一样的。跟踪源码发现，如下所示：

  执行顺序是先发布新的 tracker 事件集合到 event_broker，然后逐一遍历 event，并将其存储到 tracker_store.event 表中。

四.EventBroker 类和 SQLEventBroker(EventBroker)类

1.EventBroker 类

2.SQLEventBroker(EventBroker)类

  SQLEventBroker(EventBroker)类有个内部类 SQLBrokerEvent(Base)，定义了 events 的 3 个字段，分别为 id、sender_id 和 data。剩下的基本是对 EventBroker 基类中方法的具体实现。rasa/core/brokers/sql.py 如下所示：

五.TrackerStore 类和 SQLTrackerStore 类

1.TrackerStore 类

  表示所有 TrackerStore 的公共行为和接口，如下所示：

2.SQLTrackerStore 类

  对 TrackerStore 基类的实现，包括 InMemoryTrackerStore、RedisTrackerStore、DynamoTrackerStore、MongoTrackerStore、SQLTrackerStore。SQLTrackerStore(TrackerStore, SerializedTrackerAsText)类有个内部类 SQLEvent(Base)，定义了 events 的 7 个字段，分别为 id、sender_id、type_name、timestamp、intent_name、action_name 和 data。剩下的基本是对 TrackerStore 基类中方法的具体实现。rasa/core/tracker_store.py 如下所示：

参考文献

[1] rasa-v2024010701（报时机器人）源码：https://github.com/ai408/nlp-engineering/tree/main/知识工程-对话系统/公众号代码/rasa-v2024010701

[2] 报时机器人的 rasa shell 执行流程分析：https://z0yrmerhgi8.feishu.cn/wiki/CvASwk5SmiYkCXkqONycSxVfnJg

[3] 打通 Rasa Action Server 和 LLM 接口的尝试方法：https://z0yrmerhgi8.feishu.cn/wiki/UQa0wQBeJi6K7oknz2wcaSTnnNb

[4] 以报时机器人为例详细介绍tracker_store和event_broker：https://z0yrmerhgi8.feishu.cn/wiki/SQSGwzYR7iKSNukQDKicz1Vqnvg