问题标签 [phpcassa]

我在 cassandra 中有一个列族，它记录特定用户在指定时间段内发出的所有事件。

我正在使用由 UUID1 和 UTF8 字符串组成的复合列。我想在特定时间后选择所有列。

在下面的代码中，我尝试读取数据。最初我尝试创建一个仅在 1 索引处设置事件类型的数组，但是尽管这似乎可行，但我在日志中遇到了很多错误。现在，我试图在过去设置一个时间戳，并以此为基础创建一个 UUID1。没有错误 - 但也没有数据。

如何从指定时间开始选择列？

谢谢，

我们目前正在使用ab工具进行一些压力测试。单个插入在 cassandra 中运行良好。但是，当涉及到批量插入时，我目前正在处理 java 内存不足错误：Java Heap Space。

我有一台虚拟机，其中安装了 Ubuntu 服务器 13.04，内存为 2G

我对cassandra的内部配置了解不多。

我只是在制作大小为 100 的批量插入（100 插入 a BATCH）。

在我看到这个错误之后，我无法再cqlsh访问，nodetool几乎 1 小时都无法访问。

如何在重载时修复此错误？

注意：它不会发生在带有HTTP POST请求的单个插入上。

注意：在我的列族中，我有一个 TimeUUIDType 键，列值为ints 和varchars

更新：测试结果显示在 6000 个请求之前我没有任何问题。但是，当涉及到 7000 时，php 代码会抛出以下内容；

Error connecting to 127.0.0.1: Thrift\Exception\TTransportException: TSocket: timed out reading 4 bytes from 127.0.0.1:9160

此外，cassandra 会在繁重的负载中记录以下内容；

我正在尝试在高流量网站（使用 AWS）上使用 phpcassa，每秒大约有 50 个请求，但有时我会收到以下错误：

尝试连接到每台服务器两次，但所有尝试均失败。最后一个错误是：TException:TSocket: Could not connect to xxxx:9160 (Cannot assign requested address [99])

这里有什么问题？

哪一个最适合使用单个键空间或多个键空间来管理数据，假设一个应用程序具有更多数量的客户端。每个客户端将发送大量数据，我们将数据存储在时间序列列中如果我为每个客户端选择单独的键空间，在 Cassandra 中管理数据会好吗？如果我在我的应用程序中为一个客户端使用一个键空间，有什么优点和缺点？

假设有 10 个设备（dev01、dev02、dev03..etc）。

它以一定的间隔时间发送数据，我们收集这些数据，所以我们的数据模式是

我想将数据推送到 cassandra 中，哪种方式最好存储这些数据？

我的查询就像，

1 需要检索基于设备的当前日期数据，或某些日期范围？

2 5 设备当前日期数据？

我不确定以下将数据存储到 cassadra 的方法是最佳模型

请帮我解决这个问题，还有其他方法吗？

谢谢和问候， 坎纳达桑

我试图从 timeuuid 获取日期而不dateOf(id)在 cqlsh 中调用函数。那么，phpcassa 中是否有可以将 timeuuid 转换为 date 的函数？

如何将传感器时间序列数据存储到 cassandra？

在这里，我检查了性能

在具有 10000 个时间序列数据数据的 cassandra 复合列族单行键中，查询：select * from deviceidcomposite where did='Dev001' limit 5000

情况1：

除（行键）

案例2：

标准柱族

哪一个是时间序列模型？

还有什么更好的方法！提高我的表现

我在 cassandra 中有下表；

c_date用于按日期查询报表。

c_n是防止热点的节点数（平均分布数据的节点数）。

c_id是插入的timeuuid。

我的选择查询（cql 3）如下；

我已成功获得结果集；但是，当我使用cql_get_rows()在另一个示例（此处）上实现的功能时，

时间戳 (dateOf(id)) 无法正确解析，bigint 字段产生以下警告；

从返回的数据cql_get_rows()如下；

如何防止此函数抛出警告并获取日期格式的时间戳？（请不要建议@用法）

我需要帮助才能使用“PHPCassa”将 Cassandra 与 php 连接起来。我尝试了一下，但遇到了以下异常。我使用 Ubuntu 作为 Web 服务器。

NoServerAvailable Object ( [message:protected] => 尝试连接到每个服务器两次，但所有尝试都失败了。最后一个错误是：异常 'cassandra_InvalidRequestException' 和 /var/ 中的消息 'Keyspace 'testApp' 不存在' www/Cassandra/phpcassa/thrift/packages/cassandra/Cas​​sandra.php:138 堆栈跟踪：#0 /var/www/Cassandra/phpcassa/thrift/packages/cassandra/Cas​​sandra.php(138)：thrift_protocol_read_binary(Object(TBinaryProtocolAccelerated) , 'cassandra_Cassa...', false) #1 /var/www/Cassandra/phpcassa/thrift/packages/cassandra/Cas​​sandra.php(113): CassandraClient->recv_set_keyspace() #2 /var/www/Cassandra/phpcassa /connection.php(102): CassandraClient->set_keyspace('testApp') #3 /var/www/Cassandra/phpcassa/connection.php(84): ConnectionWrapper->set_keyspace('testApp') #4 /var/www/Cassandra/phpcassa/connection.php(222): ConnectionWrapper->__construct('testApp', '127.0.0.1:9160', NULL, true, 5000, 5000) #5 /var /www/Cassandra/phpcassa/connection.php(258): ConnectionPool->make_conn() #6 /var/www/Cassandra/phpcassa/connection.php(352): ConnectionPool->get() #7 /var/www /Cassandra/phpcassa/connection.php(287): ConnectionPool->call('describe_keyspa...', 'testApp') #8 /var/www/Cassandra/phpcassa/columnfamily.php(194): ConnectionPool->describe_keyspace () #9 /var/www/Cassandra/index.php(7): ColumnFamily->__construct(Object(ConnectionPool), 'Users') #10 {main} [string:Exception:private] => [code:protected ] => 0 [file:protected] => /var/www/Cassandra/phpcassa/connection.php [line:protected] => 233 [trace:Exception:private] =>Array ( [0] => Array ( [file] => /var/www/Cassandra/phpcassa/connection.php [line] => 258 [function] => make_conn [class] => ConnectionPool [type] => - > [args] => Array ()) [1] => Array ( [file] => /var/www/Cassandra/phpcassa/connection.php [line] => 352 [function] => get [class] = > ConnectionPool [type] => -> [args] => Array ( ) ) [2] => Array ( [file] => /var/www/Cassandra/phpcassa/connection.php [line] => 287 [function ] => call [class] => ConnectionPool [type] => -> [args] => Array ([0] => describe_keyspace [1] => testApp) ) [3] => Array ([file] => /var/www/Cassandra/phpcassa/columnfamily.php [line] => 194 [function] => describe_keyspace [class] => ConnectionPool [type] => -> [args] => Array ()) [4] = > 数组（[文件] =>/var/www/Cassandra/index.php [line] => 7 [function] => __construct [class] => ColumnFamily [type] => -> [args] => Array ( [0] => ConnectionPool Object ( [keyspace] => testApp [servers:ConnectionPool:private] => Array ([0] => 127.0.0.1:9160) [pool_size:ConnectionPool:private] => 5 [send_timeout:ConnectionPool:private] => 5000 [recv_timeout :ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => Array () [keyspace_description:ConnectionPool:private] => [max_retries ] => 5 [recycle] => 10000 [stats] => Array ([created] => 0 [failed] => 2 [recycled] => 0) [list_position] => 0) [1] => Users ) ) ) [previous:Exception:private] => )7 [function] => __construct [class] => ColumnFamily [type] => -> [args] => Array ( [0] => ConnectionPool Object ( [keyspace] => testApp [servers:ConnectionPool:private] =>数组 ( [0] => 127.0.0.1:9160 ) [pool_size:ConnectionPool:private] => 5 [send_timeout:ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组 () [keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] =>数组 ( [created] => 0 [failed] => 2 [recycled] => 0 ) [list_position] => 0 ) [1] => Users ) ) ) [previous:Exception:private] =>)7 [function] => __construct [class] => ColumnFamily [type] => -> [args] => Array ( [0] => ConnectionPool Object ( [keyspace] => testApp [servers:ConnectionPool:private] =>数组 ( [0] => 127.0.0.1:9160 ) [pool_size:ConnectionPool:private] => 5 [send_timeout:ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组 () [keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] =>数组 ( [created] => 0 [failed] => 2 [recycled] => 0 ) [list_position] => 0 ) [1] => Users ) ) ) [previous:Exception:private] =>)数组 ( [0] => ConnectionPool 对象 ( [keyspace] => testApp [servers:ConnectionPool:private] => 数组 ( [0] => 127.0.0.1:9160 ) [pool_size:ConnectionPool:private] => 5 [send_timeout :ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组 () [ keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] => Array ([created] => 0 [failed] => 2 [recycled] => 0) [list_position] = > 0 ) [1] => 用户) ) ) [previous:Exception:private] => )数组 ( [0] => ConnectionPool 对象 ( [keyspace] => testApp [servers:ConnectionPool:private] => 数组 ( [0] => 127.0.0.1:9160 ) [pool_size:ConnectionPool:private] => 5 [send_timeout :ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组 () [ keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] => Array ([created] => 0 [failed] => 2 [recycled] => 0) [list_position] = > 0 ) [1] => 用户) ) ) [previous:Exception:private] => )5 [send_timeout:ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组() [keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] => Array ([created] => 0 [failed] => 2 [recycled] => 0) [ list_position] => 0 ) [1] => Users ) ) ) [previous:Exception:private] => )5 [send_timeout:ConnectionPool:private] => 5000 [recv_timeout:ConnectionPool:private] => 5000 [credentials:ConnectionPool:private] => [framed_transport:ConnectionPool:private] => 1 [queue:ConnectionPool:private] => 数组() [keyspace_description:ConnectionPool:private] => [max_retries] => 5 [recycle] => 10000 [stats] => Array ([created] => 0 [failed] => 2 [recycled] => 0) [ list_position] => 0 ) [1] => Users ) ) ) [previous:Exception:private] => )0 [失败] => 2 [回收] => 0 ) [list_position] => 0 ) [1] => 用户 ) ) ) [上一个：异常：私人] => )0 [失败] => 2 [回收] => 0 ) [list_position] => 0 ) [1] => 用户 ) ) ) [上一个：异常：私人] => )

我刚刚通过 phpcassa 创建了 Column 系列，以下是代码

当我使用 cqlsh 并转到演示键空间时，我无法从中选择任何记录，它直接告诉我

也是相反的情况，当我使用 CREATE TABLE 语法在 cqlsh 中创建任何表时，phpcassa 无法找到它并抛出 NOTFOUND 异常。