关于注册表中不存在的连接名称的 CQL 引擎异常

Question

我在 Windows 2012 Server R2 - 64 位上尝试使用 Python Cassandra-Driver 客户端运行连接到 Cassandra 数据库时出现以下异常。我可以在我的个人笔记本电脑上运行它，但不能在托管在 Azure 上的机器上运行。我确定我缺少一些依赖项，但不确定它们是什么。

文件 "C:\Python\Python35-32\lib\site-packages\cassandra\cqlengine\connection.py"，第 190 行，在 get_connection 中引发 CQLEngineException（"Connection name '{0}' doesn't exist in the registry.".format（名称））Cassandra.cqlengine.CQLEngineException：注册表中不存在连接名称“” .

Answer 1

这是一个已知问题，将在下一版本 (3.8.0) 中修复：https://datastax-oss.atlassian.net/browse/PYTHON-649

作为解决方法，您可以查看是否可以在任何 UDT 模型定义或降级到 3.6 之前设置连接。

Answer 2

我也运行加入了这个 (cassandra-driver 3.13)，因为我不得不将 cassandra 共享模型与一些 flask 应用程序和其他用于批处理的简单组件分离。我最终发现它的工作原理是在下面的代码片段中（重要的位是 register_connection 和 set_default_connection 函数）：

import os

from cassandra.cluster import Cluster
from cassandra.cqlengine.connection import register_connection, set_default_connection
from flask_cqlalchemy import CQLAlchemy

cqldb = CQLAlchemy()
_keyspace = os.environ.get('CASSANDRA_KEYSPACE', 'persistent')
_hosts = [os.environ.get('CASSANDRA_HOST', 'cassandra')]
_port = os.environ.get('CASSANDRA_PORT', 9042)


def cassandra_session_factory():
    cluster = Cluster(_hosts, port=_port)
    session = cluster.connect()
    session.row_factory = dict_factory
    session.execute("USE {}".format(_keyspace))
    return session


_session = cassandra_session_factory()
register_connection(str(_session), session=_session)
set_default_connection(str(_session))


class MyModel(cqldb.Model):
    """
    Object representing the `model` column family in Cassandra
    """
    __keyspace__ = _keyspace

    session = _session
    session.default_fetch_size = 1000

    myfield = cqldb.columns.Text(primary_key=True, required=True)

关于注册表中不存在的连接名称的 CQL 引擎异常

CQL Engine Exception about a connection name not existing in registry

python

azure

cassandra-3.0

cqlengine