如何将JavaScript应用连接到Amazon Keyspaces？新手网站数据提取求助

一、准备Keyspaces连接前置资源 #

• 确认你的Keyspaces表字段结构（比如category_id、category_name、subcategory_id、subcategory_name这类对应分类/子分类的字段）
• 从AWS控制台Keyspaces的「连接指南」里下载sf-class2-root.crt证书文件，放到Visual Studio项目的静态资源目录（比如wwwroot/certs）

二、安装Cassandra驱动并配置连接 #

Amazon Keyspaces兼容Cassandra协议，用官方的cassandra-driver就能连接：

1. 打开Visual Studio的项目终端，执行安装命令：

   npm install cassandra-driver
   

2. 创建keyspaces-connect.js配置文件：

   const cassandra = require('cassandra-driver');
   const fs = require('fs');
   const path = require('path');
   
   // 证书路径，根据你的实际目录调整
   const certPath = path.join(__dirname, 'wwwroot/certs/sf-class2-root.crt');
   const sslOptions = {
     cert: fs.readFileSync(certPath),
     rejectUnauthorized: true
   };
   
   // 替换成你的Keyspaces信息
   const client = new cassandra.Client({
     contactPoints: ['cassandra.us-east-1.amazonaws.com'], // 你的Keyspaces区域端点
     localDataCenter: 'us-east-1', // 你的Keyspaces数据中心
     credentials: {
       username: '你的IAM用户名',
       password: '你的IAM访问密钥'
     },
     sslOptions: sslOptions,
     protocolOptions: { port: 9142 }
   });
   
   // 测试连接
   client.connect()
     .then(() => console.log('Keyspaces连接成功'))
     .catch(err => console.error('连接失败:', err));
   
   module.exports = client;
   

三、编写数据查询逻辑 #

创建data-service.js文件，实现分类数据的查询和整理：

const client = require('./keyspaces-connect');

async function getCategories() {
  // 替换成你的键空间和表名
  const query = `
    SELECT category_id, category_name, subcategory_id, subcategory_name 
    FROM your_keyspace.your_table;
  `;
  try {
    const result = await client.execute(query);
    // 把查询结果按分类分组，整理成前端易渲染的结构
    const categoryMap = new Map();
    result.rows.forEach(row => {
      if (!categoryMap.has(row.category_id)) {
        categoryMap.set(row.category_id, {
          id: row.category_id,
          name: row.category_name,
          subcategories: []
        });
      }
      categoryMap.get(row.category_id).subcategories.push({
        id: row.subcategory_id,
        name: row.subcategory_name
      });
    });
    return Array.from(categoryMap.values());
  } catch (err) {
    console.error('查询出错:', err);
    throw err;
  }
}

module.exports = { getCategories };

四、在前端页面渲染数据 #

假设你的网站是普通HTML结构，在页面中引入脚本并渲染：

<!DOCTYPE html>
<html>
<head>
  <title>分类展示</title>
  <style>
    .category { margin: 20px 0; padding: 10px; border: 1px solid #eee; }
    .category h3 { margin-top: 0; }
  </style>
</head>
<body>
  <div id="categories-wrap"></div>

  <script src="/node_modules/cassandra-driver/lib/client.js"></script>
  <script src="/keyspaces-connect.js"></script>
  <script src="/data-service.js"></script>
  <script>
    window.addEventListener('load', async () => {
      const container = document.getElementById('categories-wrap');
      try {
        const categories = await getCategories();
        // 生成HTML内容
        let html = '';
        categories.forEach(cat => {
          html += `<div class="category">
            <h3>${cat.name}</h3>
            <ul>`;
          cat.subcategories.forEach(sub => {
            html += `<li>${sub.name}</li>`;
          });
          html += `</ul></div>`;
        });
        container.innerHTML = html;
      } catch (err) {
        container.innerHTML = `<p>数据加载失败：${err.message}</p>`;
      }
    });
  </script>
</body>
</html>

关键注意事项 #

• 绝对不要把IAM密钥硬编码到代码里，生产环境用AWS Secrets Manager或者环境变量存储
• 给你的IAM用户配置AmazonKeyspacesReadOnlyAccess权限（或者更精细的查询权限）
• 如果网站部署在AWS外部，要确保Keyspaces允许公网访问；如果在AWS内部，优先用VPC端点连接

内容的提问来源于stack exchange，提问作者Roshni Bharadia