我想使用Cassandra的会话由多个Pythons线程共享。 我的流程是我有一个rabbitmq消费者。对于每个收到的消息，消费者都会向Cassandra插入数据。 有3个消费者，每个消费者被提供一个Cassandra集群对象。当一个消费者收到一个消息时，它会使用这个集群对象并将其插入到Cassandra。但是，当一个消息被收到后， session.execute(query) 就会被卡住。

ap = PlainTextAuthProvider(username=self.connection_params['username'],
                                       password=self.connection_params['password'])
            cluster = Cluster(contact_points=self.connection_params['contact_points'],
                                   port=self.connection_params['port'], idle_heartbeat_interval=10,
                                   auth_provider=ap, connect_timeout=30, protocol_version=3,
                                   load_balancing_policy=DCAwareRoundRobinPolicy(), monitor_reporting_enabled=True)
session = self.cluster.connect()
            session.set_keyspace(self.connection_params['keyspace'])