使用Node.js在Cassandra中进行异步等待

const cassandra = require('cassandra-driver');

// 创建Cassandra客户端
const client = new cassandra.Client({ contactPoints: ['127.0.0.1'], localDataCenter: 'datacenter1' });

// 连接到Cassandra集群
client.connect()
  .then(() => {
    console.log('Connected to Cassandra');
    // 在这里执行异步操作
    return performAsyncOperation();
  })
  .then(result => {
    console.log('Async operation result:', result);
    // 关闭Cassandra连接
    return client.shutdown();
  })
  .then(() => {
    console.log('Disconnected from Cassandra');
  })
  .catch(err => {
    console.error('Error:', err);
    // 关闭Cassandra连接
    client.shutdown();
  });

// 执行异步操作的函数
async function performAsyncOperation() {
  // 创建一个Promise对象
  return new Promise((resolve, reject) => {
    // 在这里执行异步操作，比如查询数据
    const query = 'SELECT * FROM table';
    client.execute(query, [], { prepare: true }, (err, result) => {
      if (err) {
        reject(err);
      } else {
        resolve(result);
      }
    });
  });
}