Kubernetes Websockets API pod exec node.js客户端发送方法

const WebSocket = require('ws');

// 创建WebSocket连接
const ws = new WebSocket('wss://<Kubernetes API服务器地址>/api/v1/namespaces/<命名空间>/pods/<Pod名称>/exec?command=<命令>&container=<容器名称>&stdin=true&stdout=true&tty=true', {
  rejectUnauthorized: false, // 忽略证书验证
  headers: {
    Authorization: 'Bearer <访问令牌>', // 替换为有效的访问令牌
  },
});

// 监听连接成功事件
ws.on('open', function open() {
  console.log('连接已建立');

  // 发送命令到Pod
  ws.send(JSON.stringify({
    kind: 'Exec',
    apiVersion: 'v1',
    command: ['sh', '-c', 'echo "Hello, Kubernetes!"'],
    container: '<容器名称>',
    tty: true,
    stdin: true,
    stdout: true,
    stderr: true,
  }));
});

// 监听消息接收事件
ws.on('message', function incoming(data) {
  console.log('接收到消息:', data);
});

// 监听连接关闭事件
ws.on('close', function close() {
  console.log('连接已关闭');
});