问题标签 [cassandra-jdbc]

我希望将图像作为字节缓冲区插入到 cassandra 表中。

表是：员工（姓名文本，图像块）

我已经使用 Java 以字节缓冲区的形式将图像存储到变量 bb 中。如何将此字节缓冲区 bb 中的数据插入到 cassandra 表中？有人可以帮忙吗？

下面是我在 Cassandra 中的示例数据库模式。

我想要列的完整限定名称。

任何帮助表示赞赏。

提前致谢。

我们从大约 20-25 个工业电机传感器中提取数据，数据存储在 cassandra 数据库中。Cassandra 目前在单个节点中运行。

下面是表结构

这张表中的数据被收集了几个月，每 5 秒一次，持续了近 24 小时，因此数据量非常大。

我正在尝试使用 java 和 dotnet 执行基于日期范围的查询，在这两种情况下我都遇到超时错误（Cassandra 在读取查询期间以一致性 LocalOne 失败（0 个副本响应超过 1 个需要））

如果我给出 100 的限制，查询就可以正常工作，否则它会失败。我尝试过的一些事情......

1) 增加查询超时。2) 将 gc_grace_seconds 减少到 100（暂时）以消除任何墓碑。

使用的查询

不确定我的表结构（主键）是否是错误的选择。它应该是 deviceid 和时间戳吗？

无法使用 jdbc 驱动程序连接 Cassandra，出现错误 java.sql.SQLException：无法创建 PoolableConnectionFactory（isValid() 返回 false）

Apache Beam JDBC IO 不适用于 Cassandra 我尝试使用 cassandra-jdbc-1.2.5.jar

这是我的pom

我也使用 SQL 和 Oracle 做了 JDBC io，但没有使用 Cassandra

并收到此错误 java.sql.SQLException: Cannot create PoolableConnectionFactory (isValid() returned false) 我想知道梁是否支持它。

我有一个 16 节点的 cassandra 集群，我正在使用 Simba Cassandra JDBC 驱动程序从每个 cassandra 节点中的外部工具（安装在每个节点中）插入 50.000 行，几乎是并行的。虽然插入发生，但有时/很少，我在（主要/通常）两个节点上收到以下错误：

执行失败：[Simba]CassandraJDBCDriver 错误设置/关闭连接：所有主机尝试查询失败（尝试：localhost/127.0.0.1:9042（com.simba.cassandra.shaded.datastax.driver.core.exceptions.ReadTimeoutException : Cassandra 在一致性 ONE 的读取查询期间超时（需要 1 个响应，但只有 0 个副本响应）））。java.sql.SQLException：[Simba]CassandraJDBCDriver 错误设置/关闭连接：所有主机尝试查询失败（尝试：localhost/127.0.0.1:9042（com.simba.cassandra.shaded.datastax.driver.core. exceptions.ReadTimeoutException：Cassandra 在一致性 ONE 读取查询期间超时（需要 1 个响应，但只有 0 个副本响应）））。引起：com.simba.cassandra.shaded.datastax.driver.core.exceptions.NoHostAvailableException：所有主机尝试查询失败（尝试：localhost/127.0.0.1：

奇怪的是它是一个 readtimeout 异常，而我只是想插入。我没有更改 .yaml 文件中的任何 read_time_out 或其他参数，因此它们是默认值。这意味着如果我尝试对 cqlsh 中的某些内容进行计数（*），我也会得到一个 readtimeout 异常。

ReadTimeout：来自服务器的错误：代码 = 1200 [协调节点超时等待副本节点的响应]消息 =“操作超时 - 仅收到 0 个响应。” info={'received_responses': 0, 'required_responses': 1, '一致性': 'ONE'}

我不知道这两个是否相关！关于可能发生的事情以及如何避免第一个错误“所有主机尝试查询失败”的任何想法？

我正在尝试使用 cdata jdbc 连接器连接到 Cassandra。但是，我找不到如何在连接 url 中提供用户名和密码。这是我的java代码。

目前，我提供的 url 没有身份验证。我如何在那里提供用户名和密码。

这种依赖的驱动因素是什么？例如在 postgres 中我们有 org.postgresql.Driver，同样我正在寻找 cassandra