无法在cqlengine中使用sync_table()创建两个以上的表

Question

我在 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=True)
    name = columns.Text(required=False)

class UserCompany(Model):
    id = columns.Integer(index=True, primary_key=True)
    user_id = columns.Integer(required=True)
    company_id = columns.Integer(required=True)

array_of_tables=[UserCompany, Company, Social]
    for table in array_of_tables:
        sync_table(table)

问题：执行代码时无法在 cassandra 中创建两个以上的表。

错误信息：

  File "test.py", line 109, in <module>
    create_tables()
  File "test.py", line 68, in create_tables
    sync_table(table)
  File "/usr/lib64/python2.6/site-packages/cassandra/cqlengine/management.py", line 259, in sync_table
    execute(qs)
  File "/usr/lib64/python2.6/site-packages/cassandra/cqlengine/connection.py", line 171, in execute
    result = session.execute(query, params, timeout=timeout)
  File "cassandra/cluster.py", line 1602, in cassandra.cluster.Session.execute (cassandra/cluster.c:27334)
  File "cassandra/cluster.py", line 3347, in cassandra.cluster.ResponseFuture.result (cassandra/cluster.c:65206)
cassandra.InvalidRequest: code=2200 [Invalid query] message="Cannot create secondary index on partition key column id"

需要您帮助解决此问题。

Answer 1

不允许为主列设置索引。我刚刚从代码中删除了它并且它起作用了。它应该如下所示。在这里，我只是使用 UUID 而不是整数，但这与实际问题无关。

class Company(Model):
    id = columns.UUID(default=uuid.uuid1(), primary_key=True))
    company_name = columns.Text(required=False)
    created_at = columns.DateTime(default=datetime.now)

class Social(Model):
    id = columns.UUID(default=uuid.uuid1(), primary_key=True)
    name = columns.Text(required=False)

class UserCompany(Model):
    id = columns.UUID(default=uuid.uuid1(), primary_key=True)
    user_id = columns.Integer(required=True)
    company_id = columns.Integer(required=True)

array_of_tables=[UserCompany, Company, Social]
    for table in array_of_tables:
        sync_table(table)

Answer 2

用户公司模型

class UserCompany(Model):
   id = columns.UUID(primary_key=True, default=uuid.uuid4)
   user_id = columns.Integer(required=True)
   company_id = columns.Integer(required=True)

公司模型

class Company(Model):
    id = columns.UUID(primary_key=True, default=uuid.uuid4)
    company_name = columns.Text(required=False)
    created_at = columns.DateTime(default=datetime.now)

社交模型

class Social(Model):
   id = columns.UUID(primary_key=True, default=uuid.uuid4)
   name = columns.Text(required=False)

使用 Cassandra 时，最好使用 UUID 作为主键，以便更好地分布并避免集群中出现热点。

完成这些更改后，您应该能够创建表，而不会遇到“无法在分区键列上创建二级索引”错误。

尝试这个改变。