三分钟使用laf搭建飞书机器人

youmeng

三分钟你可以快速实现在飞书中接入chatgpt机器人，可以直接私聊他问它问题，也可以在群里@它。

第一步：创建飞书机器人应用

在飞书开发者后台创建应用

添加机器人能力

添加我那机器人之后，点击左侧凭证与基础信息，复制好APP ID 和APP Secret备用。

第二步：前往laf创建云函数

第三步：将刚才复制的飞书appid和secret保存到laf的环境变量

环境变量: (添加完成后点击弹窗右下角【更新】按钮重启应用)

LARK_APPID：你刚才复制的飞书机器人的appid

LARK_SECRET：你刚才复制的飞书机器人的app secret

第四步：添加项目依赖包

搜索：openai 这个包，勾选后点击保存并重启

第五步：将云函数代码复制到云函数内并发布

import cloud from '@lafjs/cloud'
import axios from 'axios'
import * as  openai from "openai";
const db = cloud.database()

const OpenAIKey = cloud.env.CHAT_GPT_API_KEY;
const FeishuAppId = cloud.env.LARK_APPID;
const FeishuAppSecret = cloud.env.LARK_SECRET;

let chatGPT = null;
if (OpenAIKey) {
  const configuration = new openai.Configuration({ apiKey: OpenAIKey });
  const client = new openai.OpenAIApi(configuration);
  chatGPT = async (content) => {
    return await client.createChatCompletion({
      model: 'gpt-3.5-turbo',
      messages: [{ role: 'assistant', content }],
    });
  };
}

// 获取飞书 tenant_access_token 的方法
const getTenantToken = async () => {
  const url = 'https://open.feishu.cn/open-apis/v3/auth/tenant_access_token/internal/';
  const res = await axios.post(url, {
    'app_id': FeishuAppId,
    'app_secret': FeishuAppSecret,
  });

  return res.data.tenant_access_token;
};

const feishuReply = async (objs) => {
  const tenantToken = await getTenantToken();
  const url = `https://open.feishu.cn/open-apis/im/v1/messages/${objs.msgId}/reply`;
  let content = objs.content;
  if (objs.openId) content = `<at user_id="${objs.openId}"></at> ${content}`;
  const res = await axios({
    url, method: 'post',
    headers: { 'Authorization': `Bearer ${tenantToken}` },
    data: { msg_type: 'text', content: JSON.stringify({ text: content }) },
  });

  return res.data.data;
};

export async function main(ctx: FunctionContext) {
  const { body } = ctx
  if (body.challenge) return { challenge: body.challenge };
  
  const eventId = body.header.event_id;
  const contentsTable = db.collection('contents')
  const contentObj = await contentsTable.where({ eventId }).getOne();
  if (contentObj.data) return;

  const message = body.event.message;
  const messageContent = JSON.parse(message.content)
  let content = messageContent?.text?.replace('@_user_1 ', '') || '';
  if (!content) return

  const sender = body.event.sender;
  await contentsTable.add({
    eventId: body.header.event_id,
    msgId: message.message_id,
    openId: sender.sender_id.open_id,
    content,
    date: Date.now()
  });

  let replyContent = content;
  if (OpenAIKey) {
    const result = await chatGPT(content);
    replyContent = `${result.data.choices[0].message.content.trim()}`;
  }

  await feishuReply({
    msgId: message.message_id,
    openId: sender.sender_id.open_id,
    content: replyContent,
  });
}

第六步: 将云函数链接添加到飞书机器人

如果有报错提示（Challenge code没有返回），请检查云函数是否发布或环境变量是否添加并重启应用

第七步：为机器人添加事件订阅

点开每一个事件，点击开通权限

第八步：发布机器人

请注意编辑可用范围，默认机器人只能你自己使用

保存即可提交审核，联系对应审核人员审核通过即可使用

审核通过后可以在任意一个你有管理权限的群里添加机器人，然后搜索你创建的机器人的名字，即可添加。

第九步：添加ChatGPT回复功能

上面我们已经把机器人弄好了，但机器人还没有能力回复你的问题。现在我们来为他接入chatgpt。

到 OpenAI 的控制台中，点「Create new secret key」生成并且复制这个新生成的 Key，如本文第三步一样操作将key添加到环境变量中。

CHAT_GPT_API_KEY：你刚才新建的key

如果没有 OpenAI 账号，可以到网络中搜索一下获取方式，提前准备好。

第十步：愉快玩耍

写文章比写代码难多了。。。

有描述不清楚或不懂的地方，欢迎评论区留言，看见了我会一一解决。

Q&A

Q: 报错请求Axios 400 Error

A: 如图所示查看报错原因

如果你也是这种报错 Access denied One of the following scopes is required: [im:message:send,im:messageim:message:send as bot] 请按图操作开通指定权限

pklyo

youmeng 先赞再学

Sealos 首席道歉官

666 这云函数的代码是不是可以复用到钉钉和企业微信？

Laf 文档补全师

很好，这就去抄一份

youmeng

由于每条消息都会存入数据库，消息多了之后数据库会很大，所以写了个定时清理的云函数，有需求的小伙伴可以创建云函数并添加对应触发器即可使用。

云函数代码

import cloud from '@lafjs/cloud'
const db = cloud.database()
const _ = db.command
const timestamp = Date.now() - (1000 * 60 * 20) // 获取20min之前的timestamp
export async function main(ctx: FunctionContext) {
  const data = await db.collection('contents')
  .where({
    date: _.lt(timestamp) // 获取创建时间早于20min的数据
  })
  .remove({
    multi: true // 开启批量删除
  })
  console.log(data)
}

professorbaifan

实用

米开朗基杨

再来个企业微信版本 🙂

HypocriSY966

我是昨天做好了飞书机器人的集成，今天刚想发教程呢结果哈哈哈哈看到你发了，那我就不写了
看了代码点几个小问题
1.challenge只有第一次确认URL有效时需要，感觉不必写入函数里，可以在编写云函数前作为独立的操作
2.飞书会重复发送消息给云函数，需要注意消息幂等性。如果你不进行消息去重操作，你大概会在使用的过程中，机器人一个问题回答你好几遍，而且有些问题可能隔很久突然跳出来再给你一遍回答。
3.没有关联上下文，这会导致机器人无法根据你前面的话做出合适的回答，你问它之前的信息它没办法回答给你

米开朗基杨

HypocriSY966 你可以把优化后的代码贴出来

首席体验官

HypocriSY966 期待优化版本，我们公司也需要。

youmeng

HypocriSY966
回复问题1：为了上手就用，没必要删除这段代码。
回复问题2：下面代码就是防重复回复的。

  const eventId = body.header.event_id;
  const contentsTable = db.collection('contents')
  const contentObj = await contentsTable.where({ eventId }).getOne();
  if (contentObj.data) return;

回复问题3：好像确实没做关联上下文，确实是我的问题

HypocriSY966

首席体验官

米开朗基杨

好，我直接贴代码吧，贴教程好懒的说，得等这周欠的的作业先写完

import cloud from '@lafjs/cloud'
import axios from 'axios'

const app_id = "此处填写app id";
const app_secret = "此处填写app密码";
const tenant_token_url = "https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal";
const user_token_url = "https://open-apis/auth/v3/app_access_token/internal";
const send_message_url = "https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=user_id";
var tenant_access_token;
var user_access_token;

const tenant_token_config = {
  method: 'POST',
  url: tenant_token_url,
  headers: {
    'Content-Type': 'application/json; charset=utf-8',
  },
  data:{
    "app_id": app_id,
    "app_secret": app_secret
  }
};

const user_token_config = {
  method: 'POST',
  url: user_token_url,
  headers: {
    'Content-Type': 'application/json; charset=utf-8',
  },
  data:{
    "app_id": app_id,
    "app_secret": app_secret
  }
};

export async function main(ctx: FunctionContext) {
  const {content, chat_id, message_id} = ctx.body.event.message;

  let messageMap = cloud.shared.get('messageMap');
  if (!messageMap) {
    messageMap = new Map(); 
    messageMap.set(message_id, true); 
  } else {
    if (!messageMap.has(message_id)) { 
      messageMap.set(message_id, true); 
      if (messageMap.size > 500) { 
        const oldestElement = messageMap.keys().next().value;  
        messageMap.delete(oldestElement); 
      } 
    } else {
      return ;
    }
  }
  cloud.shared.set('messageMap',messageMap);

  if (ctx.body.header.event_type !== 'im.message.receive_v1') {
    return;
  }

  const { ChatGPTAPI } = await import('chatgpt')
  const {user_id, union_id, open_id} = ctx.body.event.sender.sender_id

  await axios(tenant_token_config)
  .then(function (response) {
    tenant_access_token = 'Bearer '+response.data.tenant_access_token;
  })
  .catch(function (error) {
    console.log(error);
  })

  let api = cloud.shared.get('api');
  if (!api) {
    api = new ChatGPTAPI({ apiKey: cloud.env.OPEN_API_KEY });
    cloud.shared.set('api', api);
  }

  let res;
  let id = cloud.shared.get('parentMessageId');
  if (!id) {
    res = await api.sendMessage(content);
  } else {
    res = await api.sendMessage(content, { parentMessageId: id });
  }
  cloud.shared.set('parentMessageId',res.id);
  
  const text ={
    "text": res.text
  }
  const stringifiedtext = JSON.stringify(text);

  const data = {
    // receive_id: chat_id,
    receive_id: user_id,
    msg_type: "text",
    content: stringifiedtext
  };

  const send_message_config = {
    method: 'POST',
    url: send_message_url,
    headers: {
      'Content-Type': 'application/json; charset=utf-8',
      'Authorization': tenant_access_token
    },
    data : data
  };

  axios(send_message_config)
  .then(function (response) {
    console.log(JSON.stringify(response.data));
  })
  .catch(function (error) {
    console.log(error);
  })
  return;
}

jveay

大锅牛逼plus~

HypocriSY966

youmeng 关于问题2，不好意思，当初草草过了一遍代码，没意识到这部分是用来实现这个功能的，我的

留意

‘Request failed with status code 400’ ‘AxiosError: Request failed with status code 400\n’ +
‘ at settle (/app/node_modules/axios/dist/node/axios.cjs:1855:12)\n’ +
‘ at IncomingMessage.handleStreamEnd (/app/node_modules/axios/dist/node/axios.cjs:2712:11)\n’ +
‘ at IncomingMessage.emit (node:events:525:35)\n’ +
‘ at endReadableNT (node:internal/streams/readable:1359:12)\n’ +
‘ at process.processTicksAndRejections (node:internal/process/task_queues:82:21)’
把响应返回时，一直报这个错

这是请求参数：
‘{“url”:“https://open.feishu.cn/open-apis/im/v1/messages/om_17560a2d48263e3b96052ef29eb6f7f9/reply","method":"post","headers":{"Authorization":"Bearer t-g1043rb7JFVPY2NSTWPT4KOVN66NTPQEUXWJDZS6″},“data”:{“msg_type”:“text”,“content”:"{\“text\”:\"<at user_id=\\\“ou_a3c4d679c878a0235f9a047914b528ec\\\”></at> K8s (also known as Kubernetes) is an open-source platform for container orchestration. It was originally developed by Google and is now maintained by the Cloud Native Computing Foundation. K8s automates the deployment, scaling, and management of containerized applications. It helps organizations and development teams manage and deploy their applications efficiently while leveraging the full potential of containerization. K8s is designed to be highly scalable and reliable, making it ideal for large-scale applications that need to be deployed across multiple servers or data centers.\“}”}}’

youmeng

留意你在用户群吗我在2群如果你也在群里@youmeng 截图我看一下我帮你解决

留意我好像知道为啥了你的机器人是不是没回复消息的权限

留意

第七步：为机器人添加事件订阅
哈哈看一下这一步是不是忘记做了

留意

youmeng 全开通了，就跟群里说的，只有测试公司，只有我一个人可能会有这种现象，正常公司用户应该是可以的，应该是需要一个正经的公司

John

大佬可以补充关联上下文的功能吗

mast

RequestID: f5d851ee-1b93-4ac3-a490-d1b9cd30c1b8

[2023-04-16 04:06:54]
“Cannot read properties of undefined (reading ‘event_id’)” “TypeError: Cannot read properties of undefined (reading ‘event_id’)\n” +
‘ at main (evalmachine.<anonymous>:74:33)\n’ +
‘ at evalmachine.<anonymous>:108:7\n’ +
‘ at Script.runInContext (node:vm:141:12)\n’ +
‘ at Script.runInNewContext (node:vm:146:17)\n’ +
‘ at FunctionEngine.run (/app/dist/support/function-engine/engine.js:31:40)\n’ +
‘ at CloudFunction.invoke (/app/dist/support/function-engine/function.js:73:36)\n’ +
‘ at handleDebugFunction (/app/dist/handler/debug-func.js:55:35)\n’ +
‘ at handleInvokeFunction (/app/dist/handler/invoke-func.js:21:59)\n’ +
‘ at process.processTicksAndRejections (node:internal/process/task_queues:95:5)’

[未知用户] 这个是怎么回事呢

‘connect ETIMEDOUT 157.240.2.14:443’ ‘Error: connect ETIMEDOUT 157.240.2.14:443\n’ + ‘ at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1494:16)’

这个是什么原因呢？
‘connect ETIMEDOUT 157.240.2.14:443’ ‘Error: connect ETIMEDOUT 157.240.2.14:443\n’ + ‘ at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1494:16)’

这个是什么原因呢？
connect ETIMEDOUT 157.240.2.14:443′ ‘Error: connect ETIMEDOUT 157.240.2.14:443\n’ + ' at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1494:16)