标签: pycassa

是否有任何与SQL相同的Cassandra查询:LIKE Con​​dition?

LIKE条件允许我们在SQL语句的where子句中使用通配符.这允许我们执行模式匹配.该LIKE条件可用于任何有效的SQL语句 - 选择,插入,更新或删除.像这样

SELECT * FROM users
WHERE user_name like 'babu%';
Run Code Online (Sandbox Code Playgroud)

与上面相同的操作一样,任何查询都可以在CLI中用于Cassandra.

sql cassandra pycassa

24
推荐指数
4
解决办法
5万
查看次数

最好的Cassandra库/ Python包装器?

我发现了lazyboypycassa - 也许还有其他人.我见过许多推荐lazyboy的网站.恕我直言项目似乎已经死了,请参阅https://www.ohloh.net/p/compare?project_0=pycassa&project_1=lazyboy

那么新项目的最佳选择是什么?谢谢.

python cassandra pycassa

17
推荐指数
1
解决办法
2万
查看次数

从另一个函数调用一个函数时,在pycassaShell中获取意外的NameError

我正在玩pycassaShell(作为CassandraTwissandra教程的一部分).当试图在shell中添加两个函数,并从另一个调用一个函数时,我得到一个错误,即Name无法识别.

这可能是非常简单的事情,但我没有找到如何做到这一点.

pycassaShell看起来像:

In [3]: def aaa(): print 5
In [4]: aaa()
5

In [5]: def bbb(): aaa()

In [6]: bbb()
---------------------------------------------------------------------------
NameError                                 Traceback (most recent call last)
...
NameError: global name 'aaa' is not defined
Run Code Online (Sandbox Code Playgroud)

python cassandra pycassa

13
推荐指数
1
解决办法
282
查看次数

Aptana 3未解决的导入 - Python

我正在尝试在Aptana 3中的Python项目中导入pycassa库,但在"import pycassa"行中它向我显示下一个错误:"Unresolved import:pycassa".我安装了pycassa,安装简单,如果我在python shell中运行"import pycassa",它运行时没有错误.如果我运行Aptana项目运行没有错误,但错误标记继续.为什么?

对不起我的英语不好.

python aptana pydev pycassa

12
推荐指数
1
解决办法
5830
查看次数

如何从cassandra中检索时间戳?

在下面的cassandra中,"获取结果"..我们可以检索列名和值.但是如何检索时间戳..是否有更好的想法通过使用时间戳来获取值

[default@sample]get user[bob];                                        
=> (column=name, value=bobdroid, timestamp=1335361733545850)
=> (column=email, value=bob@gmail.com, timestamp=1335361733545850)
=> (column=age, value=23, timestamp=1335361733545850)
=> (column=password, value=MTIz, timestamp=1335361733545850)
Returned 4 results.
Elapsed time: 4 msec(s).
Run Code Online (Sandbox Code Playgroud)

cql command-line-interface cassandra pycassa

12
推荐指数
2
解决办法
1万
查看次数

在Python中为Cassandra生成UUID

嘿,我正在使用

cf.insert(uuid.uuid1().bytes_le, {'column1': 'val1'}) (pycassa)

为Cassandra创建一个TimeUUID,但收到错误

InvalidRequestException: 
InvalidRequestException(why='UUIDs must be exactly 16 bytes')
Run Code Online (Sandbox Code Playgroud)

它不起作用

uuid.uuid1()
uuid.uuid1().bytes
str(uuid.uuid1())
Run Code Online (Sandbox Code Playgroud)

无论是.

创建与CompareWith ="TimeUUIDType"标志一起使用的有效TimeUUID的最佳方法是什么?

谢谢,
亨里克

python uuid cassandra pycassa

10
推荐指数
2
解决办法
3738
查看次数

如何使用pyspark在cassandra数据上创建RDD对象

我正在使用cassandra 2.0.3,我想使用pyspark(Apache Spark Python API)从cassandra数据创建一个RDD对象.

请注意:我不想从pyspark API执行导入CQL和CQL查询,而是想创建一个RDD,我想在其上做一些转换.

我知道这可以在Scala中完成,但我无法找到如何通过pyspark完成.

真的很感激,如果有人能指导我这个.

python scala cassandra pycassa apache-spark

9
推荐指数
1
解决办法
2204
查看次数

如何使用pycassa获取存储在Cassandra列族中的所有密钥?

有没有经验与pycassa合作的人我对它有疑问.如何获取存储在数据库中的所有密钥?

好吧,在这个小片段中,我们需要给出键以获得相关的列(这里的键是'foo'和'bar'),这很好,但我的要求是一次获取所有键(仅键)作为Python列表或类似的数据结构.

cf.multiget(['foo', 'bar'])
{'foo': {'column1': 'val2'}, 'bar': {'column1': 'val3', 'column2': 'val4'}}
Run Code Online (Sandbox Code Playgroud)

谢谢.

python cassandra pycassa

6
推荐指数
2
解决办法
7587
查看次数

pycassa TypeError:str或unicode,无法执行cassandra插入

我的脚本是python,cassandra是数据stax社区版.

TypeError: A str or unicode value was expected, but int was received instead (3902503)
Run Code Online (Sandbox Code Playgroud)

这是我在尝试插入cassandra列族时遇到的错误.

代码如下:

for x in feed:
    cf.insert(uuid.uuid4(), x)
Run Code Online (Sandbox Code Playgroud)

x是一个简单的数组,形式为"{key:value}"

错误日志表明:

    Traceback (most recent call last):
      File "C:\Users\me\Desktop\pro1\src\pro1.py", line 73, in <module>
        str("swf"): str("aws")
      File "c:\Python27\lib\site-packages\pycassa\columnfamily.py", line 969, in insert
        mut_list = self._make_mutation_list(columns, timestamp, ttl)
      File "c:\Python27\lib\site-packages\pycassa\columnfamily.py", line 504, in _make_mutation_list
        columns.iteritems())
      File "c:\Python27\lib\site-packages\pycassa\columnfamily.py", line 503, in <lambda>
        return map(lambda (c, v): Mutation(self._make_cosc(_pack_name(c), _pack_value(v, c), timestamp, ttl)),
      File "c:\Python27\lib\site-packages\pycassa\columnfamily.py", line 462, in _pack_value
        return packer(value)
      File …
Run Code Online (Sandbox Code Playgroud)

python string error-handling cassandra pycassa

5
推荐指数
1
解决办法
1187
查看次数

Python的最佳Cassandra 1.2驱动程序,我应该忘记CQL吗?

我正在为python寻找一个好的驱动程序:

1)Pycassa.它不支持CQL,他们不认为很快就会这样做.

2)https://code.google.com/a/apache-extras.org/p/cassandra-dbapi2/.

我想使用cassandra-dbapi2但是这里有一个人说"它不支持连接池负载平衡提前功能".另一方面,我可以使用PyCassa,但它不支持CQL.我应该尝试Pycassa并忘记客户端上的CQL吗?

我不关心失去ORM功能,实际上我认为它可能会更糟糕,因为它迫使你的团队学习新东西(你正在使用的ORM API上的新功能),因为SQL是人们所知道的.为什么在熟悉SQL/CQL时学习一门新语言?但这只是一个意见......

你认为最好的选择是什么?我应该忘记CQL吗?

cassandra pycassa

5
推荐指数
1
解决办法
2238
查看次数