python Cassandra connection by using python Cassandra driver and cqlengine.

cassandra_python_connection.py

__author__ = 'giasuddin'

from cassandra.cqlengine.connection import setup
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra.query import dict_factory
from cassandra.cqlengine import connection
from cassandra.policies import RoundRobinPolicy




def connect(keyspace = "test_keyspace"):
    """
    python cassandra connection by using python cassandra driver and cqlengine.
    """

    auth_provider = PlainTextAuthProvider(username="cassandra", password="cassandra")

    if connection.session is not None:
        print('\n   Already connected ')
    else:
        print('\n New connection established ......................\n')
        setup(["127.0.0.1"], keyspace, auth_provider=auth_provider, protocol_version=4, load_balancing_policy=RoundRobinPolicy())