我读了一个大文件要插入Cassandra。我试图创建一个cassandra会话，并将其传递给多个线程。我希望所有的线程使用同一个会话，以避免数千次的重新连接。
我发现池从未调用insert\u chunk函数，因为看不到日志记录。知道为什么会话不能在线程中传递给吗？我还尝试将session设置为全局而不是参数，可以调用insert\u块，但仍停留在session.prepare

def insert_chunk(chunk, session):
    logging.info("insert chunck started")
    prepared = session.prepare(...)
    for line in chunck:
       session.execute(prepared, values)

main():
        cluster = Cluster()
        session = cluster.connect()
        with open("BIG_JSON", mode="r") as _file:
            objects = ijson.items(_file, "item")
            with Pool(20) as pool:
                while True:
                    chunk = list(itertools.islice(objects, 10000))
                    if len(chunk) <= 0:
                        break
                    pool.apply_async(
                        insert_chunk,[chunk, session],
                    )
                pool.close()
                pool.join()