AWS Keyspaces sync_table() 不会立即看到表

问题描述

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

我打电话给sync_table
我看到该表开始在 Keyspaces 中创建并且定义是正确的
但是 sync_table 从这行代码 KeyError {__table_name__}

table = cluster.Metadata.keyspaces[ks_name].tables[raw_cf_name]

我可以再次调用 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'

解决方法

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';

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

keyspace_name	表名	状态
mykeyspace	我的表	创造

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

keyspace_name	表名	状态
mykeyspace	我的表	活跃

amazon-keyspaces cassandra cassandra-driver python