**头脑 Storm ：**您可以将命令封装在一个Python文件中，并在K8s主节点上运行：

import subprocess

def run_kafka_command(pod_name, kafka_command):
    command = f'kubectl exec -it {pod_name} -- bash -c "{kafka_command}"'
    result = subprocess.run(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
    return result.stdout

def run_postgres_query(pod_name, database, query):
    command = f'kubectl exec -it {pod_name} -- psql -d {database} -c "{query}"'
    result = subprocess.run(command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True)
    return result.stdout

if __name__ == "__main__":
    pod_name = "your_pod_name"
    kafka_command = "your_kafka_command"
    database = "your_database"
    query = "your_query"

    kafka_output = run_kafka_command(pod_name, kafka_command)
    print("Kafka Command Output:")
    print(kafka_output)

    postgres_output = run_postgres_query(pod_name, database, query)
    print("Postgres Query Output:")
    print(postgres_output)

字符串