القائمة
Manage and inspect AWS EMR clusters, steps, instances, studios, notebook executions, release labels, security configurations, and managed scaling using awsflow. Supports full lifecycle operations.
التثبيت باستخدام Codex أو Claude انسخ هذا Prompt والصقه في Codex أو Claude أو مساعد آخر ليراجع صفحة Skill ويثبّتها لك.
استنادا إلى تصنيف SOC المهني
Manage and inspect AWS API Gateway REST APIs, resources, methods, stages, authorizers, usage plans, and domain names using the awsflow VS Code extension APIGatewayTool.
Manage and inspect AWS CloudFormation stacks, resources, changesets, types, drift detection, and stack sets using the awsflow VS Code extension CloudFormationTool.
Query and manage CloudWatch log groups, streams, events, run Insights queries, inspect metric filters and subscriptions, and open the interactive log viewer using awsflow. Find logs from Lambda, API Gateway, Glue, RDS, ECS, Step Functions, and other AWS services.
Manage Amazon DynamoDB tables and items using awsflow. Create/delete/update tables, query and scan data, CRUD operations on items, manage TTL, backups, global tables, auto-scaling, and tags.
Manage and query AWS EC2 resources including launching/stopping/terminating instances, creating VPCs and subnets, managing security groups, volumes, snapshots, AMIs, and querying all EC2 resource types using awsflow. Full lifecycle management.
Manage AWS Glue ETL jobs, triggers, crawlers, databases, tables, workflows, and connections using awsflow. Create, update, and delete resources, inspect crawl history, and manage tags.
| name | awsflow-emr |
| description | Manage and inspect AWS EMR clusters, steps, instances, studios, notebook executions, release labels, security configurations, and managed scaling using awsflow. Supports full lifecycle operations. |
Manage and inspect EMR clusters, steps, studios, notebook executions, and related configurations.
Use this skill when the user:
Describe and manage EMR clusters, steps, studios, and configurations. ALWAYS provide params object.
List EMR clusters with optional state filter.
{ "command": "ListClusters", "params": { "ClusterStates": ["RUNNING", "WAITING"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterStates | array of strings | No | Filter by states: STARTING, BOOTSTRAPPING, RUNNING, WAITING, TERMINATING, TERMINATED, TERMINATED_WITH_ERRORS |
| CreatedAfter | string | No | ISO date string filter |
| CreatedBefore | string | No | ISO date string filter |
| Marker | string | No | Pagination marker |
Get detailed information about a cluster.
{ "command": "DescribeCluster", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
List steps in a cluster.
{ "command": "ListSteps", "params": { "ClusterId": "j-1234567890ABC", "StepStates": ["FAILED"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| StepStates | array of strings | No | Filter by step states |
| Marker | string | No | Pagination marker |
Get details of a specific step.
{ "command": "DescribeStep", "params": { "ClusterId": "j-1234567890ABC", "StepId": "s-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| StepId | string | Yes | Step ID |
List EC2 instances in a cluster.
{ "command": "ListInstances", "params": { "ClusterId": "j-1234567890ABC", "InstanceStates": ["RUNNING"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| InstanceFleetId | string | No | Instance fleet ID filter |
| InstanceGroupId | string | No | Instance group ID filter |
| InstanceStates | array of strings | No | Filter by states |
List instance fleets in a cluster.
{ "command": "ListInstanceFleets", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
List instance groups in a cluster.
{ "command": "ListInstanceGroups", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
List bootstrap actions for a cluster.
{ "command": "ListBootstrapActions", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
List EMR studios.
{ "command": "ListStudios", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| Marker | string | No | Pagination marker |
Get details of an EMR studio.
{ "command": "DescribeStudio", "params": { "StudioId": "es-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
List notebook executions.
{ "command": "ListNotebookExecutions", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| CreatedAfter | string | No | ISO date filter |
| CreatedBefore | string | No | ISO date filter |
| NextToken | string | No | Pagination token |
Get details of a notebook execution.
{ "command": "DescribeNotebookExecution", "params": { "NotebookExecutionId": "ex-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| NotebookExecutionId | string | Yes | Notebook execution ID |
List available EMR release labels.
{ "command": "ListReleaseLabels", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| NextToken | string | No | Pagination token |
| MaxResults | number | No | Maximum results |
Get details for a release label.
{ "command": "DescribeReleaseLabel", "params": { "ReleaseLabel": "emr-7.0.0" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ReleaseLabel | string | Yes | Release label |
List instance types supported for a release.
{ "command": "ListSupportedInstanceTypes", "params": { "ReleaseLabel": "emr-7.0.0" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ReleaseLabel | string | No | Release label |
Get a security configuration.
{ "command": "DescribeSecurityConfiguration", "params": { "SecurityConfigurationName": "my-config" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| SecurityConfigurationName | string | Yes | Security configuration name |
Create a new EMR cluster.
{ "command": "RunJobFlow", "params": { "Name": "analytics-cluster", "ReleaseLabel": "emr-7.0.0", "Instances": { "InstanceGroups": [{ "InstanceRole": "MASTER", "InstanceType": "m5.xlarge", "InstanceCount": 1 }] }, "ServiceRole": "EMR_DefaultRole", "JobFlowRole": "EMR_EC2_DefaultRole" } }
Add steps to a cluster.
{ "command": "AddJobFlowSteps", "params": { "JobFlowId": "j-1234567890ABC", "Steps": [{ "Name": "spark-step", "ActionOnFailure": "CONTINUE", "HadoopJarStep": { "Jar": "command-runner.jar", "Args": ["spark-submit", "--deploy-mode", "cluster", "s3://bucket/job.py"] } }] } }
Modify cluster settings.
{ "command": "ModifyCluster", "params": { "ClusterId": "j-1234567890ABC", "StepConcurrencyLevel": 2 } }
Configure auto scaling for an instance group.
{ "command": "PutAutoScalingPolicy", "params": { "ClusterId": "j-1234567890ABC", "InstanceGroupId": "ig-ABC123", "AutoScalingPolicy": { "Constraints": { "MinCapacity": 2, "MaxCapacity": 10 }, "Rules": [] } } }
Tag a cluster.
{ "command": "AddTags", "params": { "ResourceId": "j-1234567890ABC", "Tags": { "env": "prod" } } }
Remove tags from a cluster.
{ "command": "RemoveTags", "params": { "ResourceId": "j-1234567890ABC", "TagKeys": ["env"] } }
Terminate one or more clusters.
{ "command": "TerminateJobFlows", "params": { "JobFlowIds": ["j-1234567890ABC"] } }
List security configurations.
{ "command": "ListSecurityConfigurations", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| Marker | string | No | Pagination marker |
Get auto-termination policy for a cluster.
{ "command": "GetAutoTerminationPolicy", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
Get block public access configuration.
{ "command": "GetBlockPublicAccessConfiguration", "params": {} }
Get managed scaling policy for a cluster.
{ "command": "GetManagedScalingPolicy", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
Get session credentials for a cluster.
{ "command": "GetClusterSessionCredentials", "params": { "ClusterId": "j-1234567890ABC", "CredentialType": "UsernamePassword" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| CredentialType | string | Yes | Credential type |
| ExecutionRoleArn | string | No | Execution role ARN |
| DurationSeconds | number | No | Lifetime in seconds |
Get studio session mapping.
{ "command": "GetStudioSessionMapping", "params": { "StudioId": "es-ABC123", "IdentityType": "USER", "IdentityId": "user-123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
| IdentityType | string | Yes | USER or GROUP |
| IdentityId | string | Yes | Identity ID |
List studio session mappings.
{ "command": "ListStudioSessionMappings", "params": { "StudioId": "es-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
| IdentityType | string | No | USER or GROUP |
Describe job flows (legacy).
{ "command": "DescribeJobFlows", "params": { "JobFlowIds": ["j-ABC123"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| JobFlowIds | array of strings | No | Job flow IDs |
| CreatedAfter | string | No | ISO date filter |
| CreatedBefore | string | No | ISO date filter |
Application UI commands for Spark History Server, etc.
{ "command": "GetOnClusterAppUIPresignedURL", "params": { "ClusterId": "j-ABC123", "ApplicationId": "app-123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| ApplicationId | string | Yes | Application ID |
S3Tool to inspect dataEC2Tool to inspect the underlying instancesCloudWatchLogTool to read logsIAMTool to inspectGlueTool to query the catalog