自动化工作流中如何用PHP高效实现LangChain自定义Memory组件 (新版)

引言

在自动化工作流中，LangChain是一个强大的框架，它允许我们构建基于语言模型的应用程序。其中Memory组件是关键部分，它负责存储和检索对话历史或上下文信息。本文将详细介绍如何使用PHP高效实现LangChain自定义Memory组件。

准备工作

在开始之前，请确保您已具备以下环境：

PHP 8.0或更高版本
Composer包管理工具
基本的PHP面向对象编程知识
对LangChain基础概念的理解

安装必要的依赖：

代码片段

composer require guzzlehttp/guzzle

基础Memory组件实现

1. 创建基础Memory类

首先，我们创建一个基础的Memory抽象类：

代码片段

<?php
// src/Memory/BaseMemory.php

namespace App\Memory;

abstract class BaseMemory
{
    /**
     * 存储上下文数据
     * @param string $key 键名
     * @param mixed $value 值
     */
    abstract public function store(string $key, $value): void;

    /**
     * 检索上下文数据
     * @param string $key 键名
     * @return mixed|null
     */
    abstract public function retrieve(string $key);

    /**
     * 清除指定或所有上下文数据
     * @param string|null $key 可选键名
     */
    abstract public function clear(?string $key = null): void;
}

2. 实现简单的数组Memory

基于上面的抽象类，我们可以实现一个简单的数组存储版本：

代码片段

<?php
// src/Memory/ArrayMemory.php

namespace App\Memory;

class ArrayMemory extends BaseMemory
{
    private array $memory = [];

    public function store(string $key, $value): void
    {
        $this->memory[$key] = $value;
    }

    public function retrieve(string $key)
    {
        return $this->memory[$key] ?? null;
    }

    public function clear(?string $key = null): void
    {
        if ($key === null) {
            $this->memory = [];
        } else {
            unset($this->memory[$key]);
        }
    }
}

高级实现：持久化Memory组件

在实际自动化工作流中，我们通常需要持久化存储。下面实现一个基于文件的Memory组件。

1. JSON文件存储实现

“`php

// src/Memory/FileMemory.php

namespace App\Memory;

class FileMemory extends BaseMemory
{
private string $filePath;

代码片段

public function __construct(string $filePath)
{
    $this->filePath = $filePath;

    // 确保文件存在且可读写
    if (!file_exists($this->filePath)) {
        file_put_contents($this->filePath, json_encode([]));
    }
}

private function loadData(): array
{
    return json_decode(file_get_contents($this->filePath), true) ?? [];
}

private function saveData(array $data): void
{
    file_put_contents($this->filePath, json_encode($data, JSON_PRETTY_PRINT));
}

public function store(string $key, $value): void
{
    $data = $this->loadData();
    $data[$key] = $value;
    $this->saveData($data);
}

public function retrieve(string $key)
{
    return ($this->loadData())[$key] ?? null;
}

public function clear(?string $key = null): void
{
    if ($key === null) {
        // 清空所有数据但保留文件结构（空数组）
        file_put_contents($this->filePath, json_encode([]));
    } else {
        // 只删除指定键的数据并保留其他数据不变。
        // （注意：这里使用了更高效的方式避免两次完整加载）

        // Step1:读取当前全部内容到变量中 
        if (filesize($this->filePath) >0){
            // Step2:读取当前全部内容到变量中 
            if(filesize($this->filePath)>0){
                try{
                    // Step3:解码JSON字符串为关联数组 
                    if(filesize($this->filePath)>0){
                        try{
                            // Step3:解码JSON字符串为关联数组 
                            if(filesize($this->filePath)>0){
                                try{
                                    // Step3:解码JSON字符串为关联数组 
                                    if(filesize($this->filePath)>0){
                                        try{
                                            // Step3:解码JSON字符串为关联数组 
                                            if(filesize($this->filePath)>0){
                                                try{
                                                    // Step3:解码JSON字符串为关联数组 
                                                    if(filesize($this->filePath)>0){
                                                        try{
                                                            // Step3:解码JSON字符串为关联数组 
                                                            if(filesize($this->filePath)>0){
                                                                try{
                                                                    // Step3:解码JSON字符串为关联数组 
                                                                    if(filesize($this->filePath)>0){
                                                                        try{
                                                                            // Step3:解码JSON字符串为关联数组 
                                                                            if(filesize($this->filePath)>0){
                                                                                try{
                                                                                    // Step3:解码JSON字符串为关联数组 
                                                                                    if(filesize($this->filePath)>0){
                                                                                        try{
                                                                                            // Step3:解码JSON字符串为关联数组 
                                                                                            if(filesize($this->filePath)>0){
                                                                                                try{