多云中间件横向速查与跨环境隔离实战

# 列所有 RDS Aurora cluster
aws rds describe-db-clusters --region <region> \
  --query 'DBClusters[].[DBClusterIdentifier,Engine,Status,ClusterCreateTime]' \
  --output table

# 列所有 ElastiCache（Serverless + Replication Group + Cache Cluster）
aws elasticache describe-serverless-caches --region <region>
aws elasticache describe-replication-groups --region <region>
aws elasticache describe-cache-clusters --region <region>

# 列所有 MSK 集群（含 Provisioned + Serverless）
aws kafka list-clusters-v2 --region <region>

# 列所有 Amazon MQ broker
aws mq list-brokers --region <region>
aws mq describe-broker --broker-id <id> --region <region>

# CloudTrail 查 broker 创建事件（找初始 admin user 名）
aws cloudtrail lookup-events --region <region> \
  --lookup-attributes AttributeKey=EventName,AttributeValue=CreateBroker \
  --max-results 10

# 创建独立 ElastiCache Replication Group（带 TLS+AUTH）
aws elasticache create-replication-group --region <region> \
  --replication-group-id <name> \
  --engine valkey --engine-version 8.0 \
  --cache-node-type cache.t4g.micro --num-cache-clusters 1 \
  --cache-subnet-group-name <subnet-group> \
  --security-group-ids <sg-id> \
  --transit-encryption-enabled --auth-token "<password>" \
  --port 6379

# 创建 Amazon MQ for RabbitMQ broker
aws mq create-broker --region <region> \
  --broker-name <name> --engine-type RabbitMQ --engine-version 3.13 \
  --host-instance-type mq.m7g.medium \
  --deployment-mode SINGLE_INSTANCE --no-publicly-accessible \
  --subnet-ids <subnet-id> --security-groups <sg-id> \
  --users '[{"Username":"admin","Password":"<pwd>","ConsoleAccess":true}]'

# 列所有 RDS 实例
aliyun rds DescribeDBInstances --RegionId <region>

# 列 PolarDB 集群
aliyun polardb DescribeDBClusters --RegionId <region>

# 列 MSE Nacos 实例
aliyun mse ListClusters --PageNum 1 --PageSize 50

# 列 MSE Nacos namespaces（同一个 Nacos 实例下的所有 namespace）
aliyun mse ListEngineNamespaces --InstanceId <mse_instance_id>

# 拉取 Nacos 配置内容
aliyun mse GetNacosConfig --InstanceId <mse_id> \
  --NamespaceId <ns> --Group <group> --DataId <dataid>

# 更新 Nacos 配置
aliyun mse UpdateNacosConfig --InstanceId <mse_id> \
  --NamespaceId <ns> --Group <group> --DataId <dataid> \
  --Type yaml --Content "$(cat config.yaml)"

# 看所有 context（多集群环境必备）
kubectl config get-contexts

# 切 context（不要忘了带 -n namespace）
kubectl --context <ctx> -n <ns> ...

# 滚动重启所有匹配 label 的 deployment
kubectl --context <ctx> -n <ns> rollout restart deploy --selector=app.kubernetes.io/part-of=<your-app>

# 起一个临时跳板 pod（用 alpine + curl 调内网 API）
kubectl --context <ctx> -n <ns> run probe \
  --image=curlimages/curl:latest --restart=Never \
  --command -- sleep 600

# 起 mysql 客户端 pod 跳板查 RDS
kubectl --context <ctx> -n <ns> run mysql-probe \
  --image=mysql:8 --restart=Never \
  --command -- sleep infinity

# 看 pod 拉取的 Nacos 配置缓存
kubectl --context <ctx> -n <ns> exec <pod> -- cat /tmp/nacos/cache/config/<dataid>@@<group>@@<namespace>

-- 查所有运行中的事务（找长事务 / 死锁源头）
SELECT trx_id, trx_mysql_thread_id, trx_started, trx_state,
       trx_rows_locked, LEFT(trx_query, 100) AS query
FROM information_schema.innodb_trx
WHERE TIMESTAMPDIFF(SECOND, trx_started, NOW()) > 5;

-- KILL 僵尸事务（用上面查到的 trx_mysql_thread_id）
KILL <thread_id>;

-- 查锁等待
SELECT * FROM performance_schema.data_lock_waits;

-- 大表分批 DELETE（CTAS 备份 → 临时表中转 → 1000-5000/批）
CREATE TABLE main_bak_20260418 AS SELECT * FROM main WHERE <condition>;
ALTER TABLE main_bak_20260418 ADD PRIMARY KEY (id);  -- ★ 必加，否则 JOIN 全表扫死锁

DELIMITER //
CREATE PROCEDURE batch_del()
BEGIN
  DECLARE deleted INT DEFAULT 1;
  WHILE deleted > 0 DO
    DROP TEMPORARY TABLE IF EXISTS tmp_ids;
    CREATE TEMPORARY TABLE tmp_ids (id BIGINT PRIMARY KEY) AS
      SELECT id FROM main_bak_20260418 ORDER BY id LIMIT 1000;
    DELETE m FROM main m INNER JOIN tmp_ids t ON m.id = t.id;
    DELETE bak FROM main_bak_20260418 bak INNER JOIN tmp_ids t ON bak.id = t.id;
    SET deleted = ROW_COUNT();
  END WHILE;
END//
DELIMITER ;
CALL batch_del();
DROP PROCEDURE batch_del;

# 看 broker 上所有 user 的 tags
curl -s -u 'admin:<pwd>' https://<broker>.mq.<region>.on.aws/api/users | jq '.[] | {name, tags}'

# 列 vhosts
curl -s -u 'admin:<pwd>' https://<broker>/api/vhosts | jq '.[].name'

# 创建 vhost
curl -X PUT -u 'admin:<pwd>' -H 'Content-Type: application/json' \
  https://<broker>/api/vhosts/<new_vhost> -d '{}'

# 给 user 授权 vhost（read/write/configure all）
curl -X PUT -u 'admin:<pwd>' -H 'Content-Type: application/json' \
  https://<broker>/api/permissions/<vhost>/<user> \
  -d '{"configure":".*","write":".*","read":".*"}'

# 看 vhost 内所有 queue + 消费者数
curl -s -u 'admin:<pwd>' \
  'https://<broker>/api/queues/<vhost>?columns=name,consumers,messages,message_stats.publish' \
  | jq '.[] | {name, consumers, messages}'

# 列 topic
kafka-topics --list --bootstrap-server $BROKER --command-config /tmp/client.properties

# 看 consumer group + offset
kafka-consumer-groups --bootstrap-server $BROKER --command-config /tmp/client.properties \
  --describe --group <group_name>

# 复制旧 group offset 到新 group（改 group 名时零丢零重的关键）
kafka-consumer-groups --bootstrap-server $BROKER --command-config /tmp/client.properties \
  --reset-offsets --to-group <old_group> --to-group-new <new_group> --execute --all-topics

# 跨集群查日志（自己写个 wrapper 调 logcli 即可）
logcli --addr=<loki-url> query \
  '{namespace="myapp", app="backend"} |= "ERROR"' --since=1h

# Loki LogQL 常用
{namespace="x"} |= "keyword"               # 含关键词
{namespace="x"} |~ "regex.*pattern"        # 正则
{namespace="x"} | json | level="error"     # 解析 JSON 字段
sum by (level) (rate({namespace="x"}[5m])) # 按 level 聚合