go-cqhttp【弃用】#

conda create -n qqbot python=3.10 -y conda activate qqbot

wget https://github.com/Mrs4s/go-cqhttp/releases/download/v1.0.0-rc3/go-cqhttp_linux_amd64.tar.gz

https://github.com/Mrs4s/go-cqhttp/releases/download/v1.2.0/go-cqhttp_linux_amd64.tar.gz

tar -zxvf go-cqhttp_linux_amd64.tar.gz cd go-cqhttp

反向 Websocket 通信

1
servers:
2
  - ws-reverse:
3
      universal: ws://127.0.0.1:8080/onebot/v11/ws  # nonebot 监听的地址
4
      reconnect-interval: 5000

nonebot【弃用】#

python -m pip install —user pipx python -m pipx ensurepath

pipx install nb-cli

nb create

nb run

在 NapCat 配置添加反向 ws 地址，地址为 ws://127.0.0.1:8080/onebot/v11/ws, 这里的 8080 是 NoneBot 输出的端口号，/onebot/v11/ws 是 NoneBot onebot 适配器默认的路径

nb adapter install nonebot-adapter-console 测试基础功能

nb plugin install nonebot-plugin-analysis-bilibili

OpenShamrock【弃用】#

mongo常用指令#

1. 连接和切换数据库

# 连接到MongoDB服务

mongo —port 27017

# 切换到指定数据库，如果不存在则创建

use mydatabase

2. 数据库操作

# 显示所有数据库

show dbs

# 删除当前数据库

db.dropDatabase()

3. 集合操作

# 创建集合

db.createCollection(“mycollection”)

# 显示所有集合

show collections

# 删除集合

db.mycollection.drop()

4. 文档操作

插入文档

# 插入单个文档

db.mycollection.insert({name: “John”, age: 30})

# 批量插入文档

db.mycollection.insertMany([{name: “Jane”, age: 25}, {name: “Doe”, age: 22}])

查询文档

# 查询所有文档

1
db.<collection_name>.find().pretty()

# 条件查询文档

db.mycollection.find({age: {$gt: 25}})

# 查询单个文档

db.mycollection.findOne({name: “John”})

更新文档

# 覆盖更新文档

db.mycollection.update({name: “John”}, {name: “John”, age: 31})

# 局部更新文档

db.mycollection.update({name: “John”}, {$set: {age: 32}})

# 批量更新文档

db.mycollection.update({age: {lt: 30}}, {set: {status: “young”}}, {multi: true})

删除文档

# 删除单个文档

db.mycollection.remove({name: “John”})

# 删除所有文档（慎用）

db.mycollection.remove({})

1
mongodb://localhost:27017/yourDatabaseName

安装#

先安装了mongo 解压后放到/usr/local

vim /etc/mongodb.conf

1
dbpath=/usr/local/mongodb/data
2
logpath=/usr/local/mongodb/logs/mongodb.log
3
logappend=true
4
port=27017
5
bind_ip=0.0.0.0
6
fork=true

1
cd /usr/local/mongodb/bin

1
mongod -f /etc/mongodb.conf

mongosh安装解压后放到/usr/local

/usr/local/mongosh/bin/mongosh --host localhost --port 27017

一定要先关闭Mongodb再退出终端！否则重启困难。

mongod —shutdown -f /etc/mongodb.conf

mongod —repair -f /etc/mongodb.conf

注意如果修复不顺利，很有可能是权限问题

使用小技巧

bashrc中添加一行alias mongoshell='/usr/local/mongosh/bin/mongosh --host localhost --port 27017'，以后即可在终端使用mongoshell启动shell了

compass#

在windows上安装即可

windows上连接mongodb://localhost:27017/即可

如果是云服务器呢？

1. 修改 MongoDB 配置以允许远程访问

编辑 MongoDB 的配置文件 /etc/mongod.conf，找到 net 部分，并确保它如下所示（允许所有 IP 访问，请根据实际情况调整）：

1
net:
2
  port: 27017
3
  bindIp: 0.0.0.0  # 允许任何IP访问，或者指定具体的IP地址如 '192.168.1.100'

保存更改后，重启 MongoDB 服务使配置生效：

1
sudo systemctl restart mongod

2. 配置防火墙规则

确保服务器防火墙允许外部访问 MongoDB 端口（默认是 27017）。对于 UFW（Ubuntu 的默认防火墙），你可以运行以下命令来开放端口：

1
sudo ufw allow 27017

索引#

在使用 MongoDB 的 find() 方法进行查询时，MongoDB 不一定会遍历集合中的每一条数据。是否需要遍历所有文档取决于查询条件和索引的使用情况。

如果你在查询中使用的字段上没有创建索引，那么 MongoDB 将执行全表扫描（Collection Scan），这意味着它会检查集合中的每一个文档来找到匹配的记录。这种情况下，随着集合的增长，查询性能会显著下降。

但是，如果你在一个或多个字段上创建了索引，MongoDB 可以利用这些索引来快速定位到符合条件的文档，而不需要遍历整个集合。例如，如果你有一个针对 keyxx 字段的索引，并且执行 find({ keyxx: 1 }) 查询，MongoDB 将使用该索引来直接访问值为 1 的那些文档，而不是逐个检查每个文档。

为了验证 MongoDB 是否使用了索引来优化查询，你可以使用 .explain("executionStats") 方法来分析查询计划。这将告诉你MongoDB是如何执行查询的，包括是否使用了索引、扫描了多少文档等信息。

例如：

1
db.collection.find({ keyxx: 1 }).explain("executionStats")

通过这个命令，你可以看到查询的执行细节，包括是否有使用索引（index scan）还是进行了全表扫描（collection scan）。如果查询效率不如预期，考虑创建合适的索引通常是提高查询性能的第一步。不过也要注意，虽然索引可以加快读操作，但它们也会稍微减慢写操作，因为每次写入时都需要更新索引。因此，应该根据具体的使用场景来平衡索引的使用。

在compass中Indexes选项即可进行相关的操作。

迁移#

使用 mongodump 和 mongorestore

安装见mongodump工具安装及使用详解_mongodump安装-CSDN博客

这是最常用的方法之一，特别适合一次性迁移或备份恢复。

1. 在源服务器上导出数据库

   • 使用 mongodump 命令来导出你要迁移的数据库。假设你的数据库名为 mydatabase，你可以运行如下命令：

     1
     mongodump --db mydatabase --out /path/to/backup/
     

   • 这将在指定路径下创建一个包含你的数据库的备份文件夹。

2. 将备份传输到目标服务器

   • 你可以通过多种方式（如 scp, FTP, 或者直接使用云存储服务）将备份文件夹传输到目标服务器。

3. 在目标服务器上导入数据库

   • 使用 mongorestore 来恢复数据库。首先确保你在目标服务器上有MongoDB正在运行，然后执行如下命令：

     1
     mongorestore --db mydatabase /path/to/backup/mydatabase/
     

指令系统#

1
ctx.command('echo <message>')
2
  .action((_, message) => message)

定义了echo指令，（必选）参数是，[xxx]用来定义可选参数

action是回调函数，第一个参数是Argv。其余的自己定义。

模板：

1
ctx.command('test <arg1> [arg2] [arg3]')
2
  .action((_, arg1, arg2, arg3) => { /* do something */ })

如果想把参数声明为文本（空格的解析），需要改为ctx.command('echo <message:text>')

（因此文本参数通常在最后

指令可以定义选项

1
ctx.command('test')
2
  .option('alpha', '-a')          // 定义一个选项
3
  .option('beta', '-b [beta]')    // 定义一个带参数的可选选项
4
  .option('gamma', '-c <gamma>')  // 定义一个带参数的必选选项
5
  .action(({ options }) => JSON.stringify(options))

事件系统#

1
ctx.on('message', (session) => {
2
    if (session.content === '天王盖地虎') {
3
      session.send('我是二百五')
4
    }
5
  })

message是事件名称，session是参数，是一个会话对象

消息元素#

阅读rss-owl代码

1
 if (arg.merge===true) {
2
 message = `<message forward><author id="${rssItem.author}"/>${messageList.join("")}</message>`
3
}

即可学会转发消息的发送

数据库#

@seidko/messages#

实测是好用的，和sqlite一起

可以保存图片、b站分享等消息

但是没有发送者账号记录

chathub_message#

？

q78kg/messages-saver-mongodb#

没问题

message-logger#

？

QQ消息管理器中导出消息#

UTF-8-BOM

类 EewAdapter#

• 属性：

  • socket: 预留用于WebSocket连接的属性。
  • sendList: 推送目标列表，包含需要接收预警信息的目标（如群聊或私聊）。
  • botsList: 机器人白名单，指定了哪些机器人可以发送预警信息。
  • showEewLogs: 布尔值，决定是否在终端中显示预警日志。
  • showEewEmoji: 布尔值，决定输出信息中是否使用表情符号增强可读性。
  • ctx: 上下文对象，通常用于提供对Koishi框架功能的访问。
  • eewAllows: 对象，定义了不同类型的地震预警或报告是否允许被处理。

• 构造函数：

  • 初始化时接收上下文(ctx)、机器人列表(bot_list)、发送列表(send_list)、是否显示预警日志(eew_log)和是否显示表情符号(eew_emoji)作为参数，并将它们分配给相应的实例属性。

• 方法：

  • sendMessageToFriend(user_id, message): 向指定用户ID发送私信。它遍历所有可用的机器人，并通过每个机器人的sendPrivateMessage方法发送消息。
  • sendMessageToGroup(guild_id, message): 向指定群组ID发送消息。类似于sendMessageToFriend，但它调用的是机器人的sendMessage方法。
  • sendEew(data_object): 根据传入的地震数据对象决定如何处理和发送预警信息。首先检查预警类型是否允许被处理，然后根据预警类型实例化对应的预警处理器（例如ScEew, FjEew等）。接着调用处理器的eewExecute方法执行具体的预警逻辑，并通过showEewInfo方法获取格式化的预警信息。最后，根据发送列表中的目标类型（私聊或群聊），分别调用相应的方法发送预警信息。

其他细节

• 在sendEew方法中，对于eqlist类型的数据，只处理其中的No1字段，这可能意味着这些数据结构包含了多个条目，但仅对最重要的一个进行处理。

• 预警类型与具体处理器之间的映射似乎存在一个小错误：无论是cenc_eqlist还是jma_eqlist都使用了ScEew处理器实例化，而根据预期逻辑，可能应该分别为它们指定不同的处理器。

• eew变量在每次sendEew方法结束时被设置为void 0（即undefined），这可能是为了手动释放资源或重置状态。

getSenderBotList():

• 该方法用于获取所有可被允许发送消息的机器人列表。它遍历botsList中的每个ID，并与当前上下文(ctx)中活跃的机器人列表进行匹配。如果找到匹配项，则将其添加到当前机器人的列表cur_bot_list中。

setup(ws_url, time_out):

初始化WebSocket连接，使用提供的WebSocket URL (ws_url)和超时时间(time_out)。如果当前没有已存在的WebSocket连接，则创建一个新的连接。

start():

• 开始监听WebSocket事件，包括连接打开、接收到消息、连接关闭和发生错误的情况。当接收到不同类型的消息（如地震预警或心跳包）时，会调用相应的处理逻辑。对于地震预警类型的消息，将调用sendEew方法处理并发送预警信息。

stop(): - 关闭WebSocket连接，并将socket属性设置为undefined以表示无连接状态。

pause() 和 resume(): - 分别用于暂停和恢复WebSocket连接的操作。这些方法可能依赖于底层WebSocket实现的支持。

isEnable(): - 检查是否存在有效的WebSocket连接。

status(show_emoji = true): - 返回当前WebSocket连接的状态描述，支持使用表情符号增强可读性。根据WebSocket的readyState属性值，返回不同的状态描述。

info(show_emoji = true): - 提供详细的系统状态信息，包括是否开启预警、通信状态、平台数量和目标数量等。同样支持使用表情符号增强输出。

setEewSwAllows(…): - 设置不同类型的地震预警或报告是否允许被处理。这允许动态调整哪些类型的预警信息会被处理。

test2():

1
- 一个测试方法，模拟接收一条特定格式的地震预警信息(JSON字符串)，并通过`sendEew`方法处理这条消息。这对于调试和验证系统的正确性非常有用。

这段代码定义了两个类：Eew和继承自Eew的ScEew。这些类主要用于处理和展示地震预警信息。以下是详细分析：

类 Eew#

• 属性：

  • 包含了一些基本的地震信息属性，如报告时间(report_time)、编号(num)、纬度(latitude)、经度(longitude)、地区(region)、震级(mag)、发震时间(origin_time)、深度(depth)、烈度(intensity)以及类型(type)。
  • ctx: 上下文对象，用于提供对Koishi框架功能的访问。

• 构造函数：

  • 接收一个上下文对象ctx作为参数，并将其分配给实例属性。

• 方法：

  • showEewInfo(show_log, show_emoji): 返回一个字符串模板，表示如何展示地震预警信息。具体实现由子类完成。
  • eewExecute(json_data): 根据传入的JSON数据初始化地震信息。它尝试从输入的数据中提取相关字段，并为缺失的值提供默认值或使用辅助函数（如getFormatTime()）生成当前时间。
  • static test(ctx, show_emoji = true): 提供了一个静态测试方法，用于模拟一条地震预警信息，并通过showEewInConsole函数输出到控制台。这有助于验证系统在接收特定格式的信息时是否能正确响应。

函数 apply#

• 参数：

  • ctx: Koishi上下文对象，提供访问框架功能的方法。
  • config: 插件配置对象，包含所有必要的配置项。

• 配置初始化：

  • 从传入的config中提取各项设置，包括是否启用地震预警(EEW_SW)、WebSocket地址(EEW_ADDR)、超时时间(EEW_TIMEOUT)等，并为每个设置提供了默认值。

• 事件监听器：

  • 监听Koishi的生命周期事件，如ready、exit和dispose，分别在插件准备就绪、退出和销毁时执行相应的操作（例如启动或停止WebSocket连接）。

• 前置检查函数 previousCheck：

  • 在执行某些命令之前进行必要的检查，确保WebSocket地址有效且地震预警指令已启用。如果检查失败，则返回相应的错误信息。

• 命令定义：

  • 使用ctx.command方法定义了一系列命令，使用户能够通过聊天界面与插件交互。这些命令包括：
    • EEW: 地震预警菜单界面。
    • EEW.开启: 开启地震预警服务。
    • EEW.关闭: 关闭地震预警服务。
    • EEW.重置: 重置地震预警服务。
    • EEW.状态: 查看当前地震预警服务的状态信息。
    • EEW.测试: 发送一个地震预警测试消息。
    • EEW.目标: 查看地震预警推送的目标列表。
    • EEW.平台: 查看地震预警推送的机器人列表。

• 具体实现细节：

  • 对于每个命令，都会首先调用previousCheck进行前置条件检查，以确保可以安全地执行后续操作。
  • 根据不同的命令，会调用EewAdapter的不同方法来执行实际的操作，比如启动或停止WebSocket连接，或者显示状态信息等。
  • 提供了别名(alias)支持，使得用户可以通过多种方式输入相同的命令（例如，EEW.开启和EEW 开启）。

API相关信息#

1
{"Title":"緊急地震速報（予報）","CodeType":"Ｍ、最大予測震度及び主要動到達予測時刻の緊急地震速報","Issue":{"Source":"東京","Status":"通常"},"EventID":"20250401144201","Serial":4,"AnnouncedTime":"2025/04/01 14:42:50","OriginTime":"2025/04/01 14:41:47","Hypocenter":"根室半島南東沖","Latitude":43.0,"Longitude":145.9,"Magunitude":4.2,"Depth":90,"MaxIntensity":"2","Accuracy":{"Epicenter":"IPF 法（5 点以上）","Depth":"IPF 法（5 点以上）","Magnitude":"防災科研システム"},"MaxIntChange":{"String":"ほとんど変化なし","Reason":"不明、未設定時、キャンセル時"},"WarnArea":[],"isSea":true,"isTraining":false,"isAssumption":false,"isWarn":false,"isFinal":true,"isCancel":false,"OriginalText":"37 03 00 250401144250 C11 250401144147 ND20250401144201 NCN904 JD////////////// JN/// 189 N430 E1459 090 42 02 RK44209 RT10/// RC0//// 9999=","Pond":"68"}

希望增加功能：自动重启#

eew 开启做了什么？检查isEnable，如果False则setup、start

eew 重置做了什么？stop，new一个eewadapter

eew 状态做了什么？.info，而info就是检查status，status是检查isEnable和socket.readyState，只要有一个false就是无连接

isEnable做了什么？return this.socket != void 0;

socket是怎么来的？setup来的，setup具体内容即

this.socket = this.socket ?? this.ctx.http.ws(ws_url, { timeout: time_out });

解开疑惑！bug状态即isEnable返回true，即socket存在，但status是false，即socket not ready！

需要插件多加一个功能：定时（如半小时）检查status，如果false即自动进行重置开启之类的工作。

Dify学习#

1
cd dify
2
cd docker
3
cp .env.example .env
4
docker compose up -d

http://localhost/install

后端即服务，提供API接口

可以实时更新数据库

jina学习#

用来爬取网站内容 / 提供embedding模型

ollama学习#

本地部署embedding

curl -fsSL https://ollama.com/install.sh | sh

1
ollama pull bge-m3

bge-m3作为embedding模型

http://host.docker.internal:11434

卡在索引中？