Rustyrazorbladeは、彼の CQLEngine チュートリアル ブランチHEREを介して、これを実現する簡単な方法を示しています。
your_app_project/models/connection.py で次のようにすることで、接続を簡単にセットアップできます。
from cqlengine import management
from cqlengine.connection import setup
def connect():
setup(["127.0.0.1", "127.0.1.1", "127.0.1.2"], "tutorial", retry_connect=True)
management.create_keyspace("tutorial", replication_factor=1, strategy_class="SimpleStrategy")
この例では、"tutorial" は使用しているキースペース、strategy_classは C* インスタンスが使用しているレプリケーション戦略、replication_factorはリング全体に保存されるレプリケーションの量、127.0.0.1は Cassandra クラスター ノードの IP アドレスです。 (これにはリストまたは文字列を渡すことができます) retry_connectは、接続に失敗した場合に再接続を試みるかどうかを指定します。
ここから、新しい C* ユーザーが混乱するのは非常に簡単です。これは、C* テーブルを同期する前、または C* クエリを使用する前に、いつでも呼び出すことができます。
したがって、次のようなことを行う必要があります。
from cqlengine.management import sync_table
from models.connection import connect
from models.somemodels import MyCassandraModel
# This will fire off our previously setup 'connect' method
connect()
# This will setup the Model as a table in your C* DB
sync_table(MyCassandraModel)
CQLEngine setup() が適切に実行されている限り、これを manage.py にドロップすることもできます。