需要查询或筛选 Google Cloud Dataproc…

在 Google Cloud Dataproc 环境中，通过 Node.js 脚本查询集群和作业的详情或列表，并按状态、名称、标签等条件过滤。

适用场景

解决思路

1. 所有脚本使用 Node.js 执行；将 <param_name> 和 <param_value> 替换为实际值。
2. Bash 执行格式：`node <skill_dir>/scripts/<script_name>.js '{"<param_name>": "<param_value>"}'`
3. PowerShell 执行格式：`node <skill_dir>/scripts/<script_name>.js '{\"<param_name>\": \"<param_value>\"}'`
4. 脚本会自动从各种 .env 文件加载环境变量；除非脚本执行因缺少环境变量失败，否则不要要求用户设置变量。
5. get_cluster：获取一个 Dataproc 集群。参数 clusterName：string，非必填；传集群短名称，例如对于 "projects/my-project/regions/us-central1/clusters/my-cluster"，传 "my-cluster"，project 和 region 从 source 继承。
6. get_job：获取一个 Dataproc 作业。参数 jobId：string，非必填；传作业 ID，例如对于 "projects/my-project/regions/us-central1/jobs/my-job"，传 "my-job"，project 和 region 从 source 继承。
7. list_clusters：列出并过滤 Dataproc 集群。参数 filter：string，非必填；过滤器大小写敏感，语法为 field = value [AND [field = value]] ...；field 可为 status.state、clusterName 或 labels.[KEY]，其中 [KEY] 是标签键；value 可为 * 以匹配所有值；status.state 可为 ACTIVE、INACTIVE、CREATING、RUNNING、ERROR、DELETING、UPDATING、STOPPING 或 STOPPED，其中 ACTIVE 包含 CREATING、UPDATING、RUNNING，INACTIVE 包含 DELETING、ERROR、STOPPING、STOPPED；clusterName 是创建时提供的集群名；仅支持逻辑 AND，以空格分隔的项视为隐式 AND。参数 pageSize：integer，非必填，默认 20，表示单页最多返回的集群数。参数 pageToken：string，非必填，来自先前 ListClusters 调用的分页令牌。
8. list_jobs：列出并过滤 Dataproc 作业。参数 filter：string，非必填；过滤器大小写敏感，语法为 field = value [AND [field = value]] ...；field 可为 clusterName、status.state 或 labels.[KEY]，其中 [KEY] 是标签键；value 可为 * 以匹配所有值；status.state 可为 PENDING、RUNNING、CANCEL_PENDING、JOB_STATE_CANCELLED、DONE、ERROR 或 ATTEMPT_FAILURE；仅支持逻辑 AND，以空格分隔的项视为隐式 AND；建议按 clusterName 过滤以提高查询性能。参数 jobStateMatcher：string，非必填，指定作业状态匹配器应匹配 ALL、仅 ACTIVE 或仅 NON_ACTIVE 作业，默认 ALL，支持 ALL、ACTIVE、NON_ACTIVE。参数 pageSize：integer，非必填，默认 20，表示单页最多返回的作业数。参数 pageToken：string，非必填，来自先前 ListJobs 调用的分页令牌。

适用边界 · 注意事项

• 不适用于非 Google Cloud Dataproc 环境中的集群或作业管理。
• 该技能只提供获取与列出查询，不适用于创建、更新、删除集群或提交、取消作业等变更操作。
• 若执行环境没有 Node.js，或无法访问 Dataproc API/缺少必要凭证，则不可用。