问题标签 [datastax]

我们需要每天将数百万条记录加载到 Cassandra 并使数据可搜索。如果我们使用 sstableloader 将记录加载到 Cassandra，它们会被 solr 索引吗？solr api 是加载记录的唯一方法吗？

什么 C# 类型相当于 Datastax Cassandra C# 驱动程序中的 timeuuid？

我正在编写一个简单的用户跟踪服务，并希望访问最新的用户历史记录。我正在尝试创建一个与此创建语句等效的表：

我做了以下课程：

我正在使用这个语句在 Cassandra 中创建表：

但这给了我下表：

正如你所看到的，类型create_date是timestamp而不是timeuuid。

我试过Guid而不是DateTime，但这给了uuid我打电话的时候.CreateIfNotExists()。

我应该使用原始 CQL3 来代替并显式创建表吗Guid？我想这将允许我从/向 Cassandra读写（使用在 FluentCassandra 项目中找到的）？！（回想一下：我正在使用 Datastax 驱动程序）DateTimeCreateDatetimeuuidGuidGenerator

我正在尝试编写一个运行 Pig 的 EMR 作业，该作业写入 DSE，我们将使用它来提供服务。不幸的是，我无法让 Pig 写入 DSE，因此我将问题分解为仅连接到 DSE 节点并尝试写入它。这就是我正在做的

在 Cassandra 节点上：

从本地机器

当我这样做时，我收到以下错误：

刚刚使用新的 datastax 4.0 启动并运行了一个单节点集群。效果很好。我们使用 hive 来构建和查询我们的数据。在服务器上它自己。我可以启动 hive $>dse hive 和查询表就好了。当我尝试使用最新的 Hive ODBC 驱动程序运行相同的查询时，我看到了这个错误。它连接得很好，我可以查询键空间并查看表格。但是当我尝试运行查询时。看起来地图/红色进入队列，但随后出现以下错误。

关于我应该尝试什么的任何想法？提前感谢大家可以提供的任何想法和建议/帮助。干杯，埃里克

当我尝试在 ubuntu 12.04（通过 Datastax 的dsc20软件包安装）上启动 cassandra 作为服务时，如下所示：

$ sudo 服务 cassandra 启动

它说

*无法访问 Cassandra 的 pidfile

并且日志中没有其他消息或任何内容。

但是当我尝试以 root 用户身份运行时（sudo cassandra -f），它可以正常工作并且 cassandra 已启动。在尝试调试时，我发现在尝试以非 root 用户身份运行时， 我收到了以下消息：

包装有问题吗？包没有正确安装/配置？？

我正在从 DataStax 运行 Pig 示例：http ://www.datastax.com/docs/datastax_enterprise3.1/solutions/about_pig#pig-read-write 。我正在使用 DataStax Enterprise 3.1.2。但是当我想将数据保存回 Cassandra 时：

我得到以下输出：

日志文件是：

我做错了什么？对我来说，它看起来像一个错误，因为当我在创建表时在 CQL 中使用字符串而不是整数时，示例运行良好。

谢谢

我试图通过调用session.executeAsync()而不是session.execute()数据库写入来加速我们的代码。

我们有数据库连接可能断开的用例，当前execute()当连接丢失（集群中没有主机可达）时，前一个会抛出异常。我们可以捕获这些异常并重试或将数据保存在其他地方等......

使用executeAsync()，看起来没有任何方法可以满足这个用例 -ResultSetFuture需要访问返回的对象以检查结果，这将破坏首先使用的目的executeAsync()......

有没有办法在 executeAsync() 调用的任何地方添加一个监听器（或类似的东西），它将异步通知其他一些代码数据库写入失败？

这有关系吗？数据税 1.0.2 Java 1.7.40

Cassandra Python 驱动程序的问题是返回的“未来”对象通过副作用添加回调。这意味着“未来”是不可组合的，就像Future来自 Javascript 或 Scala 的 a 是可组合的一样。我想知道是否有一种模式可用于将不可组合的未来转变为可组合的未来（最好没有泄漏内存。）

查看Datastax 的 Cassandra Python 驱动程序的性能部分，我看到了他们如何创建一系列可连续链接的插入查询的示例。即这种模式的稍微复杂的版本：

作为玩具示例非常有用。完成一个查询后，将再次执行另一个等效查询。该方案允许他们实现 7k 写入/秒，而不尝试“链接”回调的版本限制在 2k 写入/秒左右。

我一直在努力创造某种机制，使我能够重新获得确切的机制，但无济于事。有人想出类似的东西吗？

我是卡桑德拉的新手。我按照DataStax Community Edition中提到的说明在 Windows 7 64 位上安装了 DataStax Cassandra 社区版。我遵循完全相同的说明，但由于某种原因，我无法连接到 OpsCenter。然后我去尝试手动启动 OpsCenter 服务。我收到以下错误。

Windows 无法在本地计算机上启动 DataStax OpsCenter Community 2.0.6。有关详细信息，请查看系统事件日志。如果这是一项非 Microsoft 服务，请联系服务供应商，并参阅服务特定的错误代码 1。

任何帮助将不胜感激。

谢谢

初始日志

INFO [main] 2014-03-14 11:01:53,329 启动 Jetty 服务器：{:port 61621,:host nil,:ssl? 假的，：加入？错误} INFO [初始化] 2014-03-14 11:01:53,356 新 JMX 连接 (127.0.0.1:7199) INFO [初始化] 2014-03-14 11:01:53,374 新 JMX 连接 (127.0.0.1:7199)信息 [码头] 2014-03-14 11:01:53,393 码头服务器启动错误 [初始化] 2014-03-14 11:01:53,416 线程“初始化”中的异常错误 [初始化] 2014-03-14 11:01： 53,418 clojure.lang.ExceptionInfo: throw+: {:type :bad-permissions, :message "无法找到 cassandra.yaml 配置文件。如果您的配置文件没有在 Cassandra 安装中找到，请在OpsCenter 集群配置文件的 Cassandra 部分并重新启动 opscenterd。检查以​​下目录：[\"/etc/dse/cassandra/cassandra.yaml\" \"/etc/cassandra/conf/cassandra.yaml\" \"/etc/cassandra/cassandra.yaml\" \"C:\\Program Files\ \DataStax Community\\utils\\conf\\cassandra.yaml\"]"} {:object {:type :bad-permissions, :message "找不到 cassandra.yaml 配置文件。如果您的配置文件不在 Cassandra 安装中，请在 OpsCenter 集群配置文件的 Cassandra 部分设置“conf_location”选项并重新启动 opscenterd。检查以下目录：[\"/etc/dse/cassandra/cassandra.yaml\"\"/etc/cassandra/conf/cassandra.yaml\"\"/etc/cassandra/cassandra.yaml\"\"C: \\Program Files\\DataStax Community\\utils\\conf\\cassandra.yaml\"]"}, :environment {tar-location "C:

将 cassandra.yaml 文件复制并添加到 utils\conf 中，现在在日志文件中出现以下错误

新日志

15,128 在 60 年代重新连接。错误 [StompConnection 接收器] 2014-03-17 12:12:16,130 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:12:16,130 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:13:17,137 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:13:17,137 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:14:18,140 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:14:18,140 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:15:19,152 未能连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:15:19,152 在 60 秒内重新连接。错误 [StompConnection 接收器] 2014-03-17 12:16:20,156 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:16:20,156 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:17:21,159 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:17:21,159 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:18:22,162 无法连接到 127.0.0.1:61620:java.net.ConnectException：连接被拒绝：连接 INFO [StompConnection 接收器] 2014-03-17 12:18:22,162 重新连接在 60 年代。错误 [StompConnection 接收器] 2014-03-17 12:19:23,175 未能连接到 127.0。

导入 datastax cassandra-driver(python) 时出现以下错误

错误

这是代码