class CassandraContainer(image: str = 'cassandra:latest', **kwargs)ΒΆ

Cassandra database container.

Example

>>> from testcontainers.cassandra import CassandraContainer
>>> from cassandra.cluster import Cluster, DCAwareRoundRobinPolicy

>>> with CassandraContainer("cassandra:4.1.4") as cassandra, Cluster(
...    cassandra.get_contact_points(),
...    load_balancing_policy=DCAwareRoundRobinPolicy(cassandra.get_local_datacenter()),
... ) as cluster:
...    session = cluster.connect()
...    result = session.execute("SELECT release_version FROM system.local;")
...    result.one().release_version
'4.1.4'