首页
/ Follow: CouchDB 变更和数据库更新通知工具

Follow: CouchDB 变更和数据库更新通知工具

2024-12-24 09:37:22作者:胡易黎Nicole

安装指南

要安装 Follow 模块,请在终端中运行以下命令:

npm install follow

项目使用说明

Follow 是一个用于监听 CouchDB 数据库变更的 Node.js 模块。它可以在浏览器中使用(测试版),并且可以通过 NPM 安装。Follow 的主要目标是提供一个简单易用的 API,用于在 CouchDB 数据库发生变更时通知用户。

示例

以下是一个简单的示例,展示了如何使用 Follow 模块监听 CouchDB 数据库的变更:

var follow = require('follow');
follow("https://example.iriscouch.com/boogie", function(error, change) {
  if(!error) {
    console.log("Got change number " + change.seq + ": " + change.id);
  }
});

在这个示例中,Follow 模块会监听 https://example.iriscouch.com/boogie 数据库的变更,并在每次变更时调用回调函数。

项目API使用文档

简单API: follow(options, callback)

follow 函数接受两个参数:

  1. options: 一个包含配置选项的对象或字符串。
  2. callback: 每次数据库发生变更时调用的回调函数。

选项参数

  • db: 数据库的完整 URL(支持基本认证)。
  • since: 开始监听的序列号,可以使用 "now" 从最新的变更开始。
  • heartbeat: CouchDB 响应的超时时间(默认:30000 毫秒)。
  • feed: 可选,但仅支持 "continuous"
  • filter: 过滤器,可以是设计文档的路径或一个返回布尔值的 JavaScript 函数。
  • query_params: 可选,用于过滤函数的查询参数。

回调函数

回调函数接受两个参数:

  • error: 错误对象,通常为 null
  • change: 包含变更信息的对象。

对象API

Follow 模块还提供了一个基于 EventEmitter 的 API,允许更灵活的监听和处理变更。

var follow = require('follow');

var opts = {}; // 同上
var feed = new follow.Feed(opts);

feed.db = "http://example.iriscouch.com/boogie";
feed.since = 3;
feed.heartbeat = 30 * 1000;
feed.inactivity_ms = 86400 * 1000;

feed.filter = function(doc, req) {
  if(doc.stinky || doc.ugly)
    return false;
  return true;
}

feed.on('change', function(change) {
  console.log('Doc ' + change.id + ' in change ' + change.seq + ' is neither stinky nor ugly.');
});

feed.on('error', function(er) {
  console.error('Since Follow always retries on errors, this must be serious');
  throw er;
});

feed.follow();

事件

Feed 对象是一个 EventEmitter,支持以下事件:

  • start: 在任何 I/O 操作之前触发。
  • confirm_request: 数据库确认请求发送时触发。
  • confirm: 数据库确认时触发。
  • change: 数据库发生变更时触发。
  • catchup: 数据流追上确认步骤中的 update_seq 时触发。
  • wait: Follow 空闲,等待下一个数据块时触发。
  • timeout: Follow 未在规定时间内收到心跳时触发。
  • retry: 重试计划时触发。
  • stop: 数据流停止时触发。
  • error: 发生错误时触发。

项目安装方式

Follow 模块可以通过 NPM 安装,安装命令如下:

npm install follow

安装完成后,你可以在 Node.js 项目中使用 require('follow') 来引入模块。

热门项目推荐
相关项目推荐

项目优选

收起
open-eBackupopen-eBackup
open-eBackup是一款开源备份软件,采用集群高扩展架构,通过应用备份通用框架、并行备份等技术,为主流数据库、虚拟化、文件系统、大数据等应用提供E2E的数据备份、恢复等能力,帮助用户实现关键数据高效保护。
HTML
74
55
openHiTLSopenHiTLS
旨在打造算法先进、性能卓越、高效敏捷、安全可靠的密码套件,通过轻量级、可剪裁的软件技术架构满足各行业不同场景的多样化要求,让密码技术应用更简单,同时探索后量子等先进算法创新实践,构建密码前沿技术底座!
C
50
39
HarmonyOS-ExamplesHarmonyOS-Examples
本仓将收集和展示仓颉鸿蒙应用示例代码,欢迎大家投稿,在仓颉鸿蒙社区展现你的妙趣设计!
Cangjie
258
66
mybatis-plusmybatis-plus
mybatis 增强工具包,简化 CRUD 操作。 文档 http://baomidou.com 低代码组件库 http://aizuda.com
Java
20
0
Cangjie-ExamplesCangjie-Examples
本仓将收集和展示高质量的仓颉示例代码,欢迎大家投稿,让全世界看到您的妙趣设计,也让更多人通过您的编码理解和喜爱仓颉语言。
Cangjie
177
41
advanced-javaadvanced-java
Advanced-Java是一个Java进阶教程,适合用于学习Java高级特性和编程技巧。特点:内容深入、实例丰富、适合进阶学习。
JavaScript
399
103
RuoYi-VueRuoYi-Vue
🎉 基于SpringBoot,Spring Security,JWT,Vue & Element 的前后端分离权限管理系统,同时提供了 Vue3 的版本
Java
168
37
RuoYi-Cloud-Vue3RuoYi-Cloud-Vue3
🎉 基于Spring Boot、Spring Cloud & Alibaba、Vue3 & Vite、Element Plus的分布式前后端分离微服务架构权限管理系统
Vue
26
18
hyperionhyperion
仓颉语言实现的TCP通信框架,支持添加自定义编解码器,积木式添加IoFilter处理入栈出栈消息。仓颉redis-sdk和activemq4cj项目使用了该框架。
Cangjie
113
16
CangjieCommunityCangjieCommunity
为仓颉编程语言开发者打造活跃、开放、高质量的社区环境
Markdown
892
0