def init__(self):
    self.cluster = Cluster('', protocol_version=4, load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='datacenter1'))
    self.session = self.cluster.connect('')
def init__(self):
    self.cluster = Cluster(, protocol_version=4, load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='datacenter1'))
    self.session = self.cluster.connect()