KnowForge/Apache Atlas 2.5.0 简体中文
钩子

Couchbase

qianmoQqianmoQ· 更新于 2026-09-28· 阅读 3 分钟· 0 次阅读
登录后可跨设备保存划线和私人笔记登录

Apache Atlas Couchbase 桥接器

该桥接器通过 DCP 协议连接到 Couchbase 集群，对集群中存储的文档进行实时分析与元数据提取。提取到的元数据随后通过 Atlas 的 REST API 发送至 Atlas。

配置

该桥接器使用环境变量进行配置。

Atlas REST API

环境变量说明默认值
ATLAS_URLAtlas REST API 的 URL"http://localhost:21000"
ATLAS_USERNAMEAtlas REST API 的用户名"admin"
ATLAS_PASSWORDAtlas REST API 的密码"admin"

Couchbase DCP 连接

环境变量说明默认值
CB_CLUSTERCouchbase 集群连接字符串"couchbase://localhost"
CB_USERNAMECouchbase 集群用户名"Administrator"
CB_PASSWORDCouchbase 集群密码"password"
CB_ENABLE_TLS是否使用 TLSfalse
CB_BUCKET要监控的 Couchbase bucket"default"
CB_COLLECTIONS要监控的集合列表，以逗号分隔，每个集合表示为 {scope}.{collection}
DCP_PORT要使用的 DCP 端口11210
DCP_FIELD_THRESHOLD一个阈值，用于指示某字段需在每个集合已分析消息中出现的百分比达到该值后才会被发送到 Atlas0
DCP_SAMPLE_RATIO要分析的 DCP 消息的百分比，以 0 到 1 之间的短整数形式表示。1

运行桥接器

在以下命令中，请将 <VARNAME> 和 <version> 替换为相应的值。

  • 使用 export <VARNAME>=... 设置环境变量，或在下一条命令前加上这些变量。
  • 运行 java -cp couchbase-bridge-<version>.jar com.couchbase.atlas.connector.CouchbaseHook。
  • 验证 Atlas 集群上已创建相应的 couchbase_cluster、couchbase_bucket 对象。
  • 在 Couchbase 集群上更新部分文档后，验证 Atlas 集群上已创建相应的 couchbase_scope、couchbase_collection 和 couchbase_field 对象。

评论

登录后参与评论

正在加载评论…