'Init the connection to the InfluxDB server.'

def init(self):

    if (not self.export_enable):
        return None
    try:
        cluster = Cluster([self.host], port=int(self.port), protocol_version=int(self.protocol_version))
        session = cluster.connect()
    except Exception as e:
        logger.critical(("Cannot    connect    to    Cassandra    cluster    '%s:%s'    (%s)" % (self.host, self.port, e)))
        sys.exit(2)
    try:
        session.set_keyspace(self.keyspace)
    except InvalidRequest as e:
        logger.info('Create    keyspace    {}    on    the    Cassandra    cluster'.format(self.keyspace))
        c = ("CREATE    KEYSPACE    %s    WITH    replication    =    {    'class':    'SimpleStrategy',    'replication_factor':    '%s'    }" % (self.keyspace, self.replication_factor))
        session.execute(c)
        session.set_keyspace(self.keyspace)
    logger.info('Stats    will    be    exported    to    Cassandra    cluster    {}    ({})    in    keyspace    {}'.format(cluster.metadata.cluster_name, cluster.metadata.all_hosts(), self.keyspace))
    try:
        session.execute(('CREATE    TABLE    %s    (plugin    text,    time    timeuuid,    stat    map<text,float>,    PRIMARY    KEY    (plugin,    time))    WITH    CLUSTERING    ORDER    BY    (time    DESC)' % self.table))
    except Exception:
        logger.debug(('Cassandra    table    %s    already    exist' % self.table))
    return (cluster, session)
