0

我是新来的cassandra-driver==3.25.0。我已经创建了一个模型Model并尝试同步它。问题：

  1. 我打电话sync_table
  2. 我看到表开始在 Keyspaces 中创建并且定义是正确的
  3. 但是从这行代码中sync_table引发了一个异常KeyError {__table_name__}table = cluster.metadata.keyspaces[ks_name].tables[raw_cf_name]
  4. 我可以sync_table再次打电话，一段时间后它工作正常

所以我假设它可能会从 Keyspaces 延迟，所以cassandra-driver在同步表上有某种等待，或者你能指出文档吗？

class Users(Model):
    __keyspace__ = 'aura'
    __table_name__ = 'users'
    __connection__ = 'aws_keyspace'

    user_id = columns.UUID(primary_key=True)
    tags = columns.Map(key_type=columns.Text(), value_type=columns.Text())

cluster = Cluster(...)
session = cluster.connect()
connection.register_connection('aws_keyspace', session=session, default=True)
sync_table(Users)

完全例外：

Traceback (most recent call last):
  File "/usr/lib/python3.6/runpy.py", line 193, in _run_module_as_main
    "__main__", mod_spec)
  File "/usr/lib/python3.6/runpy.py", line 85, in _run_code
    exec(code, run_globals)
  File "models.py", line 69, in <module>
    sync_table(AttachmentsByUsers)
  File "python3.6/site-packages/cassandra/cqlengine/management.py", line 190, in sync_table
    _sync_table(m, connection=connection)
  File "python3.6/site-packages/cassandra/cqlengine/management.py", line 274, in _sync_table
    table = cluster.metadata.keyspaces[ks_name].tables[raw_cf_name]
KeyError: 'users'
4

1 回答 1

1

Amazon Keyspaces 以非阻塞方式创建表。由于它是异步的，您可能不会立即看到该表。此链接提供有关如何监视系统表以检查表何时可用的指南。https://docs.aws.amazon.com/keyspaces/latest/devguide/functional-differences.html#functional-differences.table-keyspace-management

以下查询将在 CQL 中显示您的表的状态

SELECT keyspace_name, table_name, status FROM system_schema_mcs.tables
WHERE keyspace_name = 'mykeyspace' AND table_name = 'mytable';

是否仍在创建表，查询的输出将如下所示：

键空间名称 表名 地位
我的密钥空间 我的表 创造

如果表已成功创建并且处于活动状态，则查询的输出如下所示：

键空间名称 表名 地位
我的密钥空间 我的表 积极的
于 2021-06-30T20:25:41.803 回答