问题标签 [couchbase-java-api]

我写了一个hbase java客户端如下。

以下是输出

我已经使用 hbase shell 在 hbase 中创建了一个表。我在 OS X EI Captian 上运行 HDP 2.5 和我的 eclipse 代码。
我在本地路径中复制了 hbase-site.xml。

这是我的示例代码，它JsonDocument从 couchbase 服务器返回列表。

我想返回Map而不是返回。我的List返回类型是Map<String, JsonDocument>。我尝试了toMap方法，但它对我不起作用。

我想在 Java 中将文档作为批量插入到 Couchbase 中。那么在 java.. 中为每个文档生成密钥的标准程序是什么？

我在 Google Container Engine 和 Kubernetes 上使用 Docker 映像部署了一个 4 节点 Couchbase 集群。我能够访问 Couchbase 控制台、查看存储桶、查询等。现在，几天后，我访问控制台 URL，然后出现 Couchbase 初始设置屏幕！好像这是一个全新的安装。我可以看到节点和 pod 都还在运行。在我的带有 Docker 集群（无 Kubernetes）的 Windows 机器上也有类似的问题。我重新部署了那个。还有其他人经历过吗？

这是我原来问题中的一个错字。以下是我观察到的。

我的查询看起来像这样 -

String query = select * from table1 where guid is not missing and doc_type='xyz' and (guid in $guid_list);

我的 guid_list 如下 - List listOfGuid = new ArrayList<>(); listOfGuid.add("a1b3594f-0b76-4c54-8206-db2c16286320");

com.couchbase.client.java.document.json.JsonObject placeHolders = com.couchbase.client.java.document.json.JsonObject.create() .put("guid_list", JsonArray.from(listOfGuid));

N1qlQuery 语句 = N1qlQuery.parameterized(query,placeHolders);

这不起作用。但是，如果我尝试用单引号传递 guid_list 并在我的查询中对列表进行硬编码，它就可以正常工作。不知道为什么当我将它作为列表传递时它不起作用。是因为当我作为列表传递时，它以双引号 ["a1b3594f-0b76-4c54-8206-db2c16286320"] 而不是 ['a1b3594f-0b76-4c54-8206-db2c16286320'] 的形式出现。

我正在尝试使用参数化的 N1QL 查询，但它无法识别 json 占位符并引发不正确的语法异常。

代码：

我计划将数据存储到基于沙发的集群中。

我想知道如果我的沙发底座在以下情况下发生故障会发生什么：[考虑没有发生的活动交易]

1. 一个节点从集群中掉线。（我的假设是在节点修复并启动后，它将与其他节点同步，并且数据会在那里）。另外，请告诉我它同步后是否还会丢失任何数据？
2. 集群出现故障并已修复并重新启动。

请让我知道上述场景的数据持久性类比。

我正在尝试优雅地处理 Couchbase 引导失败，而不是让应用程序启动失败。这个想法是使用“Couchbase 即服务”，这样如果我无法连接到它，我应该仍然能够返回降级的响应。通过使用 Couchbase 异步 API，我已经能够在一定程度上实现这一点；RxJava FTW。

问题是，当服务器关闭时，Couchbase Java 客户端会发疯并不断尝试连接到服务器；据我所知，这样做的课程ConfigEndpoint在放弃之前尝试了多少次是没有限制的。这会使日志充满java.net.ConnectException: Connection refused错误。我想要的是让它尝试几次，然后停止。

有什么可以提供帮助的想法吗？

编辑：

这是一个示例应用程序。

重现问题的步骤：

1. svn export https://github.com/asarkar/spring/trunk/beer-demo.
2. 从beer-demo目录中，运行./gradlew bootRun. 等待应用程序启动。
3. 从另一个控制台，运行curl -H "Accept: application/json" "http://localhost:8080/beers". 由于无法连接到 Couchbase，客户端请求将超时，但 Couchbase 客户端将持续淹没控制台。

我正在使用 Couchbase-Java-Client-2.5.0 和 couchbase-server-community_4.5.1-ubuntu14.04_amd64.deb。

我在集群中有两个节点，两个节点都在 AWS 中。

尝试运行代码时，我在控制台中收到连接超时和信号断开连接。如果我使用单个节点，则运行相同的代码。

使用的代码：

控制台输出：

我正在使用 scala observables 从 couchbase 获取项目，然后我使用 map、flatMap、zip 来转换结果。问题是，如果 couchbase 中不存在某个项目，那么例如，.zip它不会仅调用 onComplete。例子：

所以我想要：

1. 返回 k -> v 的映射
2. 我让 .zip 将 k 耦合到返回的 v （我希望 v 类似于Noneif 不存在。
3. 我看到如果 db 中不存在任何项目，则根本不调用 zip。

在运行上面的代码后，我想到了扫描ids输入参数，并为每个没有用 value 压缩的参数添加一个 id 到它的值，但这就像添加另一个流，我希望 zip 处理现有和不存在的行。

我该如何处理？如何.zip处理现有行和非现有行？