使用couchbase java客户端实现在Couchbase中无法上传文档

Question

以下是要求和面临的问题。

要求：在Docker启动时，应将文档上传到couchbase存储桶。这些文档可以被另一个Storm拓扑读取。

解决方案：

1] cbdocloader使用cbdocloader，我们可以将多个文档上传到存储桶，但Storm无法读取这些文档。 +行为不一致，有时有效，有时不行。

2423 [main] WARN n.s.m.t.SerializingTranscoder - Failed to decompress data
java.util.zip.ZipException: Not in GZIP format
at java.util.zip.GZIPInputStream.readHeader(GZIPInputStream.java:165) ~
[?:1.8.0_144]
at java.util.zip.GZIPInputStream.<init>(GZIPInputStream.java:79) ~
[?:1.8.0_144]
at java.util.zip.GZIPInputStream.<init>(GZIPInputStream.java:91) ~
[?:1.8.0_144]
at net.spy.memcached.transcoders.BaseSerializingTranscoder.decompress(BaseSerializingTranscoder.java:181) [storm-enrichment-5.4.2-100007-jar-with-dependencies.jar:5.4.2-100007]

2]实现Couchbase java客户端1.x上传文件所面临的问题不一致，因为有时它用于上传文件，有时不上传。最多只上传了2份文件。

com.couchbase.client.vbucket.config.ConfigParsingException: Number of vBuckets must be a power of two, > 0 and <= 65536 (got 0)
at com.couchbase.client.vbucket.config.DefaultConfigFactory.parseCouchbaseBucketJSON(DefaultConfigFactory.java:215)
at com.couchbase.client.vbucket.config.DefaultConfigFactory.parseJSON(DefaultConfigFactory.java:127)

3]实现Couchbase java客户端2.x上传文件

在docker启动时，启用以连接到localhost：8091，

com.couchbase.client.deps.io.netty.channel.AbstractChannel $AnnotatedConnectException: Connection refused: localhost/127.0.0.1:11210
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:225)
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:291)

Answer 1

使用1.x，尝试将文件夹中的所有文档在单个连接中上传到Couchbase，最后称为shutdown。

打开连接和关闭是繁重的操作，可能会导致问题。