我正在尝试使用cassandrapython cqlengine来访问cassandra数据库，当列不是列表类型时，我能够进行过滤。
我得到以下错误消息：
d =cClass().filter(lastname='text',age=2,input__contains='a')
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/cqlengine-0.21.0-py3.4.egg/cqlengine/operators.py",
浏览 0提问于2016-10-13得票数 0
我刚刚开始在python中使用cqlengine与Cassandra合作。
我试着跟踪这个并尝试运行这个脚本：
from cqlengine import columns
from cqlengine import Model
from cqlengine import connection
from cqlengine.management import sync_table
import uuid
class ExampleModel(Model):
example_id = columns.UUID(primary_key=True, default=uuid.uuid4
浏览 8提问于2015-01-16得票数 3
回答已采纳
我试着创建一个表，但是得到了这个错误-
keyspace = cluster.metadata.keyspaces[ks_name]
KeyError: 'cqlengine'
型号：
import uuid
from cqlengine import columns
from cqlengine.models import Model
from datetime import datetime
from cqlengine.management import sync_table
class Tickets(Model):
ticket_id = colu
浏览 0提问于2016-02-19得票数 1
回答已采纳
我遵循了cassandra cqlengine教程。
import uuid
from cassandra.cqlengine import columns
from cassandra.cqlengine import connection
from datetime import datetime
from cassandra.cqlengine.management import sync_table
from cassandra.cqlengine.models import Model
class ExampleModel(Model):
example_id =
浏览 0提问于2016-12-27得票数 0
我希望通过它的django模型创建一个包含两个primary_key的表，如下所示：
class UserView(Model):
email= columns.Text(primary_key=True)
entryLink= columns.Text(primary_key=True)
date= columns.Date(default=datetime.date.today())
但是，当我想要创建如下表时：
>>> from cqlengine import connection
>>> from cqlengine.man
浏览 2提问于2013-07-12得票数 2
回答已采纳
我试图使用cassandra通过kafka连接。cqlengine似乎以前是一个独立的项目，我正在使用的参考代码就是在那个时候编写的。
所以以前，cqlengine.management有create_keyspace，cassandra.cqlengine.management有create_keyspace_simple
我正在尝试创建密钥空间。
create_keyspace_simple('meetup', 'SimpleStrategy', 1)
但是，我得到了这个错误。警告：
/Users/a/anaconda/lib/python2.7/site
浏览 0提问于2016-02-28得票数 1
1回答
我有一个带有计数器类型列的模型如下：
from cqlengine import columns
from cqlengine.models import Model
class CountView(Model):
entryLink=columns.Text(primary_key=True)
visited=columns.Counter()
但是，当我想从这个模型创建表时，如下所示：
>>> from cqlengine import connection
>>> from cqlengine.management import cr
浏览 2提问于2013-07-11得票数 1
回答已采纳
我的目的是在一个单独的进程中创建cqlengine.models.Model实例，并通过队列将其发送到数据库管理器。
不幸的是，如果使用multiprocessing queue，我将获得TypeError
模型
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class MyModel(Model):
__keyspace__='mykeyspace'
class Meta:
get_pk_field = 'u
浏览 2提问于2017-03-03得票数 1
我在centos服务器上安装了python 2.7和django 1.5。我也安装了cqlengine，但是当我想运行我的项目时发生了这个错误: can not import model cqlengine CAn任何人都可以帮我做些什么..谢谢
浏览 1提问于2013-07-23得票数 0
我正在用python创建模型，下面是我的代码
from uuid import uuid4
from uuid import uuid1
from cassandra.cqlengine import columns, connection
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.management import sync_table
class BaseModel(Model):
__abstract__ = True
deleted = columns.Boolea
浏览 2提问于2016-12-23得票数 0
回答已采纳
我有一个关于如何通过CQLEngine在Cassandra中创建无价值的列的问题。我的意思是，出于某种目的，我希望将信息存储在列名中，而不是列值中。但在CqlEngine中，您应该在模型文件中运行项目之前定义列名。谢谢你的帮助。
浏览 3提问于2013-07-22得票数 3
我是Django的初学者，已经开发了一个使用mysql作为主DB的应用程序，但在我的下一个项目中，我必须使用使用Cassandra，但不使用 (它是using的包装器？)。
我不知道该怎么开始？我的意思是应该如何在哪里创建db连接，然后在models.py文件中创建模型？
我应该在init.py文件中创建连接吗?在views.py中吗？什么是最有效的方法？
如果有人提供了一个简单的配置和一个模型，(对于未来的读者也是如此)将是很棒的。
浏览 3提问于2014-12-16得票数 0
1回答
我正在使用Python学习Cassandra对象映射器，我有下面的小程序来填充数据库表。这个很好..。
from cassandra.cqlengine.connection import setup
from cassandra.cqlengine.management import sync_table
from cassandra.cqlengine.models import Model
from cassandra.cqlengine import columns
from uuid import uuid4
##import Courses
class Courses(Mode
浏览 0提问于2019-03-14得票数 0
回答已采纳
我正在尝试在Cassandra中创建一个冻结列表，这样我就可以使用该列作为主键，如果我手动运行查询，就可以做到这一点。 some_field frozen <list<int>> 但是我很难弄清楚如何在Python中使用cqlengine， some_field = columns.List(columns.Integer(), primary_key=True) 我如何使用cqlengine来完成同样的事情？ 编辑:最终代码片段如下所示， from cassandra.cqlengine import columns
from cassandra.cqlengine
浏览 23提问于2019-01-07得票数 0
回答已采纳
我输入了一个小的演示循环，以便在Cassandra中插入随机值，但只有最后一条记录被持久存储到数据库中。我使用的是来自datastax的cassandra-driver和它的对象建模库。Cassandra版本是3.7，Python是3.4。你知道我做错了什么吗？
#!/usr/bin/env python
import datetime
import uuid
from random import randint, uniform
from cassandra.cluster import Cluster
from cassandra.cqlengine import connection,
浏览 2提问于2016-08-15得票数 1
回答已采纳
我想为Cassandra使用来自的ORM (用数据创建类，并在不编写太多CQL =的情况下自动创建表)
我已经通过docker在本地主机上部署了一个Cassandra服务器，并尝试像在他们的中所写的那样做
from cassandra.cluster import Cluster
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.management import sync_table, create_keyspace_si
浏览 13提问于2021-12-02得票数 1
from cassandra.cqlengine import models as cassandra_models
class BaseCassandraMixin(cassandra_models.Model):
meta = columns.Text()
is_active = columns.Boolean(index=True)
created_at = columns.DateTime()
updated_at = columns.DateTime()
class Meta:
abstract = True 我正在尝试
浏览 22提问于2021-06-25得票数 1
回答已采纳
我最近刚开始在python 3上使用Cassandra。
我有一个模型，它包含一组用户定义的类型：
# model.py
import uuid
from datetime import datetime
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.usertype import UserType
class Hobby(UserType):
priority = columns.Integer()
浏览 11提问于2017-05-03得票数 1
回答已采纳
1回答
我使用驱动程序的对象Mapper在运行时定义Cassandra表列(需求与这些类似)。在运行时解析表、列名和列类型。
我试图在运行时使用“type”来定义类，以定义cassandra cqlengine模型。
看起来像python驱动程序中定义的Model类向模型添加了一个元类
@six.add_metaclass(ModelMetaClass)
类模型(BaseModel)：
..。
是否有一种使用类型来定义模型的方法？在定义模型类时，我看到了以下错误
from cassandra.cqlengine.models import Model
from cassandra.cqlengine
浏览 2提问于2018-10-13得票数 0
回答已采纳
我有一个跟随者ColumnFamily
class UniqueUserDealAction(models.Model):
deal_id = columns.Text(primary_key=True)
action = columns.Text(primary_key=True)
imei1 = columns.Text(primary_key=True)
imei2 = columns.Text(primary_key=True)
event_time = columns.DateTime()
created_at = columns.Da
浏览 1提问于2016-01-15得票数 0
1回答
我正在使用python 3.4.0中的cassandra和Cassandra-Driver2.5.0(和using模型)。
应用程序数据分布在:一个用于管理的密钥空间和每个用户一个密钥空间。我需要查询两个键空间: master+custom。
我编写了一个用于键空间切换的小类，如下所示：
with keyspace(new_keyspace):
#do stuff with new_keyspace
#do stuff with previous keyspace
我的第一个版本是：
class keyspace(object):
def __init__(self, new
浏览 2提问于2015-05-19得票数 1
回答已采纳
我和Cassandra DB一起运行Django。Django模板中的url标记将cassandra.cqlengine.columns.UUID变量转换为UUID('uuid_identifier')形式。
表达式{% url 'myapp' uuid %}的结果是类似于.../UUID('uuid_identifier')的url。如果您正在等待.../uuid_identifier形式的url，这会导致问题。
在Django模板中推荐或正确使用cassandra.cqlengine.columns.UUID变量是什么？
我需要写自己的过滤器
浏览 7提问于2017-02-05得票数 2
我正在自定义服务器上的一个码头容器中运行cassandra。
我像这样启动卡桑德拉码头：
docker run --name cassandra -p 9042:9042 -d cassandra:latest
当我想通过python cassandra驱动程序从datastax连接到服务器时，如下所示：
from cassandra.cqlengine import connection
connection.setup(["http://myserver.myname.com"], "cqlengine", protocol_version=3)
引发异
浏览 18提问于2021-12-22得票数 0
回答已采纳
在Cassandra中，为了获得像sum、avg、min、max这样的聚合数据，我们使用如下查询：
SELECT avg(race_points) FROM cycling.cyclist_points WHERE id=e3b19ec4-774a-4d1c-9e5a-decec1e30aac;
但是，在cqlengine中如何做到这一点呢？我有包含姓名和年龄的列。我想从列表中得到平均年龄。请帮助我在cqlengine中检索avg(age)。
浏览 3提问于2017-05-24得票数 0
使用Cassandra python驱动程序映射器cqlengine创建带有地图集合的模型时，似乎只能在地图值上创建索引
class Foo(Model):
id = columns.UUID(partition_key=True)
time_id = columns.UUID(primary_key=True, clustering_order='DESC')
bar = columns.Map(columns.Ascii(), columns.Double(), index=True)
将产生一个表，如
cqlsh:baz> DESCRIBE
浏览 0提问于2016-02-19得票数 2
如何在django cassandra模型中定义varchar字段。 from cassandra.cqlengine import columns
from django_cassandra_engine.models import DjangoCassandraModel
class ChatEvent(DjangoCassandraModel):
interview_id = columns.UUID(partition_key=True)
fire_time = columns.DateTime(primary_key=True, clustering_order=
浏览 28提问于2020-10-23得票数 1
回答已采纳
1回答
我有卡桑德拉模型
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class StudentModules(Model):
"""Model for Student get."""
__table_name__ = 'students'
student_id = columns.UUID(primary_key=True, default=uuid4)
student_nam
浏览 0提问于2016-07-12得票数 2
回答已采纳
1回答
我正在学习使用Python的cassandra，特别是使用cqlengine的Django 2。我试图在数据库中搜索以搜索参数开头的字符串，但我想让它不区分大小写。因此，如果我有以下数据
-------------------------------
| PKID | String |
-------------------------------
| 1234 | FOObar |
| 4321 | FoOBar |
| 5665 | IreALLy |
| 5995 |
浏览 2提问于2018-05-20得票数 4
1回答
当我尝试运行我的程序并从Django框架在Cassandra数据库中插入一条记录时，一个错误告诉我:错误的请求:未知的标识符id我该怎么办？这是错误：
CQLEngineException at /registered/
Bad Request: Unknown identifier id
Request Method: GET
Request URL: http://127.0.0.1:8000/registered/?txtID=3&txtName=3&txtUsername=3&txtPassword=3
Django Version:
浏览 0提问于2014-01-11得票数 0
我正在运行一个python(3.4)烧瓶应用程序的aws豆茎。当我登录到ec2 shell并尝试在本地运行烧瓶应用程序时，它会正常运行，并且很容易从远程cassandra获取数据。但是，在从cassandra中获取数据时，AWS运行的应用程序一直在httpd/error_log中抛出以下错误。
ERROR in app: Exception on /user/1003 [GET]
Traceback (most recent call last):
File "/opt/python/run/venv/lib/python3.4/site-packages/flask/app.py&#
浏览 0提问于2016-10-27得票数 0
回答已采纳
我用python编写了以下类，并使用cqlengine作为cassandra DB的对象映射器。
class Company(Model):
id = columns.Integer(index=True, primary_key=True)
company_name = columns.Text(required=False)
created_at = columns.DateTime(default=datetime.now)
class Social(Model):
id = columns.Integer(index=True, primary_key
浏览 2提问于2015-09-26得票数 0
我想知道如何使用CQL3中的集合，我可以将值插入列表，但只插入一个值，这样我就不能在我的列表中添加一些值--我想这样做:在CQL3中：
UPDATE users
SET top_places = [ 'the shire' ] + top_places WHERE user_id = 'frodo';
在CqlEngine中：
connection.setup(['127.0.0.1:9160'])
TestModel.create(id=1,field1 = [2])
此代码将将2添加到我的列表中，但当我插入新值时，它将替换为list中的旧值。
浏览 1提问于2013-08-16得票数 4
回答已采纳
在芹菜任务中异步执行的每个insert查询(小查询)都有问题。在同步模式下，当我确实插入所有已完成的工作时，但是当它在apply_async()中执行时，我得到如下结果：
OperationTimedOut('errors=errors=errors={}, last_host=***.***.*.***, last_host=None, last_host=None',)
回溯：
Traceback (most recent call last):
File "/var/nfs_www/***/env_v0/local/lib/python2.7/site-pac
浏览 0提问于2014-07-16得票数 7
1回答
我对cassandra非常陌生。请帮我找出我的代码中的错误之处。
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class app_modules(Model):
__table_name__ = 'app_modules'
module_id = columns.UUID(primary_key=True)
module_name = columns.Text()
description = columns.Tex
浏览 2提问于2016-02-09得票数 2
我有代码
from uuid import uuid4
from uuid import uuid1
from cassandra.cqlengine import columns, connection
from cassandra.cqlengine.models import Model
from cassandra.cqlengine.management import sync_table
class BaseModel(Model):
__abstract__ = True
id = columns.UUID(primary_key=True, defaul
浏览 12提问于2017-01-17得票数 1
回答已采纳
我正在使用django- cassandra -engine python库来使用django中的cassandra数据库。我想知道是否有一种方法可以连接到多个cassandra集群，并为cqlengine模型指定连接。
浏览 1提问于2018-06-26得票数 2
使用的应用程序：
django 1.9~
当试图在管理站点注册我的模型时，我会得到以下错误：
Typerror：'ModelMetaClass‘对象不可迭代
我的models.py：
from cassandra.cqlengine import columns
from cassandra.cqlengine import models
class ApiModel(models.Model):
id = columns.BigInt(primary_key=True)
content = columns.Text()
creat
浏览 3提问于2016-02-20得票数 1
SELECT blobasinet(columnname) from table ;
system.blobasinet(columnname)
-------------------------------------------
192.168.97.12
192.168.96.9 此查询将返回Blob字段的IP字符串 此查询的cqlengine版本是什么？
浏览 15提问于2019-02-15得票数 0
1回答
我使用cassandra数据库和django，我想使用Django-rest框架工作中的序列化器来序列化数据。
models.py
import uuid
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class Users(Model):
read_repair_chance = 0.05 # optional - defaults to 0.1
uid = columns.UUID(primary_key=True, default=uui
浏览 2提问于2015-10-18得票数 4
我有一个用python编写的web服务器，它使用cassandra的python驱动程序与Cassandra数据库进行交互。当我使用gunicorn http服务器启动这个python服务器时，我的请求将被处理而没有错误。但是，当我在第一次请求后使用uwsgi http服务器运行同一服务器时，必须将一些数据写入Cassandra表，cassandra将引发一个错误。
cassandra.OperationTimedOut: errors={}，last_host=127.0.0.1
在python中的session.prepare()函数调用中会引发错误。
浏览 5提问于2015-06-15得票数 2
回答已采纳
我正在使用和的组合，通过Django应用程序与Cassandra进行通信。
下面是如何使用用户定义的Type列定义模型(仅限于示例)：
from cassandra.cqlengine import columns
from cassandra.cqlengine.usertype import UserType
from django_cassandra_engine.models import DjangoCassandraModel
class UserAddress(UserType)
street = columns.Text()
number = columns.
浏览 2提问于2020-05-05得票数 1
回答已采纳
我想在pyCharm中运行我的第一个Django cassandra代码。
我的代码在Django控制台上运行得很流畅，但在.py文件中却无法正常工作。以下是错误：
C:\Python27\python.exe "D:/Developer Center/PyCharm/DJangoCassandra/MyApp/testFile.py"
Traceback (most recent call last):
File "D:/Developer Center/PyCharm/DJangoCassandra/MyApp/testFile.py", line 3,
浏览 4提问于2014-01-08得票数 1
2回答
当我尝试使用运行在Windows2012 Server R2 - 64位上的Python Cassandra-Driver客户端连接到Cassandra DB时，我得到了以下异常。我可以在我的个人笔记本电脑上运行，但不能在托管在Azure上的机器上运行。我确信我遗漏了一些依赖项，但我只是不确定它们是什么。
文件"C:\Python\Python35-32\lib\site-packages\cassandra\cqlengine\connection.py"，行190，在get_connection提升CQLEngineException(“连接名称'{0}‘不存在于注
浏览 21提问于2016-09-27得票数 7
回答已采纳
我的卡桑德拉桌是这样的：
uid | flwuid | tuuid
------------------------+----------------------------+--------------------------------------
0x50f893bf620d628f0500 | 0x527ce3c3c5ebc4dd7e8b4567 | 1e970c24-488d-11e3-b19a-7054d219d35c
0x505a31a507b8d04b0005 | 0x526a66cbc5ebc4d
浏览 1提问于2013-11-15得票数 3
回答已采纳
我是蟒蛇的新手。我有个小项目。我使用的是conda虚拟环境，其中我编写了一个管道类，如下所示：
from cassandra.cqlengine import connection
from cassandra.cqlengine.management import sync_table, create_keyspace_network_topology
from recentnews.cassandra.model.NewsPaperDataModel import NewspaperDataModel
from recentnews.common.Constants import DEF
浏览 3提问于2017-05-31得票数 0
回答已采纳
我正在django项目中设置cassandra引擎，我成功地运行了服务器，但当我在管理站点中单击myapp的模型时，我得到了错误：
Settings' object has no attribute 'CASSANDRA_FALLBACK_ORDER_BY_PYTHON
我首先同步cassandra，然后迁移它，之后我运行服务器没有错误，但在管理网站上，当我想把数据放入我的模型时，得到了这个错误
For database I use django_cassandra_engine
DATABASES = {
'default': {
浏览 0提问于2019-04-17得票数 1
在Django中，CQLSH语句的等价物是什么？
SELECT * FROM table_name WHERE string LIKE '%pattern%';
如何在django中实现这一点？我试过了
result = table.objects.filter(string__contains='pattern')
但是它给出了以下错误
[Invalid query] message="Cannot use CONTAINS on non-collection column string"
我已经为搜索字段创建了一个自定义索引，并且原始的LIK
浏览 0提问于2021-03-10得票数 1
我试图使用cqlengine或cql(python)从Cassandra2.0中选择timestamps列，并且得到了错误的结果。
这是我从cqlsh (或节俭)处得到的："2013-09-23 00:00:00-0700“
这就是我从cqlengine和cql本身得到的：“\x00\x00\x01AG\x0b\xd5 5\xe0”
如果要复制错误，请尝试如下：
开放cqlsh
创建表测试(名称varchar主键，dt时间戳)
插入表测试(‘测试’，'2013-09-23 12:00') <<<是的，我尝试用另一种方式添加.
从测试中选
浏览 5提问于2013-09-23得票数 2
回答已采纳
我有卡桑德拉模型
import uuid
from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model
class MyModel(Model):
...
...
created_at = columns.TimeUUID(primary_key=True,
clustering_order='DESC',
default=uuid.uuid1)
浏览 2提问于2017-05-05得票数 1
回答已采纳
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
