使用Python高效获取OpenShift ConfigMap数据教程

import openshift as oc

if __name__ == '__main__':
    project_selector = oc.selector('projects')
    projects = project_selector.objects()
    for project in projects:
        name = project.model.metadata.name
        oc.invoke('project', name) # 切换项目上下文
        # 尝试获取ConfigMaps，但此方法仅返回名称列表
        # 原始的oc get configmaps命令默认不显示数据内容
        tokens = oc.invoke('get', ['configmaps']).actions()[0].as_dict()['out'].replace('\n', ' ').split(' ')
        configmap_names = [x for x in tokens if len(x) > 0 and not x.isupper()]
        print(f"项目: {name}, ConfigMaps: {configmap_names}")

import openshift as oc
import json

def get_configmap_data_via_invoke():
    """
    使用 oc.invoke 模拟命令行获取所有项目的 ConfigMap 数据。
    """
    all_configmap_data = {}

    projects = oc.selector('projects')
    for project in projects.objects():
        project_name = project.name()
        print(f"\n正在处理项目: {project_name} (通过 oc.invoke)")

        project_cms = {}
        # 切换到当前项目上下文
        with oc.project(project_name):
            # 获取当前项目下所有ConfigMap的名称
            # 使用 '-o name' 格式可以得到每行一个的资源名称，例如 "configmap/my-config"
            configmaps_names_output = oc.invoke('get', ['-o', 'name', 'configmaps'])

            # 遍历每个ConfigMap名称，获取其详细数据
            for cm_name_line in configmaps_names_output.out().splitlines():
                # 确保处理的名称是 "configmap/<name>" 格式
                if not cm_name_line.startswith('configmap/'):
                    cm_name_line = f"configmap/{cm_name_line}"

                # 获取单个ConfigMap的JSON数据
                cm_json_output = oc.invoke('get', ['-o', 'json', cm_name_line])

                try:
                    manifest = json.loads(cm_json_output.out())
                    # 从解析后的JSON中提取 'data' 字段
                    data = manifest.get('data', {}) 
                    cm_actual_name = cm_name_line.split('/')[1]
                    project_cms[cm_actual_name] = data
                    print(f"  - ConfigMap: {cm_actual_name}, Data: {data}")
                except json.JSONDecodeError as e:
                    print(f"  - 解析JSON失败 ({cm_name_line}): {e}")
                except KeyError:
                    print(f"  - ConfigMap {cm_name_line} 中未找到 'data' 字段。")

        all_configmap_data[project_name] = project_cms
    return all_configmap_data

if __name__ == '__main__':
    # 调用 oc.invoke 方式的示例
    # config_maps_via_invoke = get_configmap_data_via_invoke()
    # print("\n通过 oc.invoke 获取的ConfigMap数据汇总:")
    # print(json.dumps(config_maps_via_invoke, indent=2, ensure_ascii=False))
    pass

import openshift as oc

def get_all_configmap_data_via_selector():
    """
    遍历所有项目，获取每个项目下所有ConfigMap的数据。
    这是推荐的方法，因为它直接与OpenShift API交互。
    """
    all_configmap_data = {}

    # 1. 选择所有项目
    projects_selector = oc.selector('projects')
    for project_obj in projects_selector.objects():
        project_name = project_obj.name()
        print(f"\n正在处理项目: {project_name} (通过 oc.selector)")

        project_configmaps = {}
        # 2. 切换到当前项目上下文
        # with oc.project() 上下文管理器确保后续操作都在此项目下进行
        with oc.project(project_name):
            # 3. 在当前项目下选择所有ConfigMaps
            configmaps_selector = oc.selector('configmaps')

            # 4. 遍历每个ConfigMap API对象
            for cm_obj in configmaps_selector.objects():
                cm_name = cm_obj.name()

                # 5. 直接从API对象中获取数据
                # cm_obj.as_dict() 会返回ConfigMap的完整API表现形式（Python字典）
                # 'data' 键包含了ConfigMap的具体配置内容
                try:
                    cm_data = cm_obj.as_dict().get('data', {})
                    project_configmaps[cm_name] = cm_data
                    print(f"  - ConfigMap: {cm_name}, Data: {cm_data}")
                except Exception as e:
                    print(f"  - 获取ConfigMap {cm_name} 数据失败: {e}")

        all_configmap_data[project_name] = project_configmaps

    return all_configmap_data

if __name__ == '__main__':
    # 调用 oc.selector 方式的示例
    config_maps_via_selector = get_all_configmap_data_via_selector()

    print("\n通过 oc.selector 获取的ConfigMap数据汇总:")
    import json
    print(json.dumps(config_maps_via_selector, indent=2, ensure_ascii=False))