How to Connect AWS ECS with Lambda: A Step-by-Step Guide

Select Language:

You can have your Lambda function receive responses from an ECS service by setting up proper communication between them. Here’s how you can do it:

First, make sure your Lambda function and ECS service are in the same Virtual Private Cloud (VPC). This allows them to communicate smoothly. Next, adjust the security groups for both services. You want to allow inbound traffic on the necessary port for ECS from your Lambda’s security group, and the outbound rules on Lambda’s security group should permit communication with the ECS security group.

Then, decide on the right endpoint to connect to your ECS service. Using an Application Load Balancer (ALB) that’s set up in front of ECS is the best option, as it provides a stable DNS name within your network. Only if absolutely necessary, you can temporarily use the private IP address of an ECS task, but this is not recommended for production deployments.

Once your setup is ready, your Lambda function can make HTTP requests to the ECS service. To do this, you can use a popular request library like Requests in Python. Here’s a simple example:

python
import requests

def lambda_handler(event, context):
try:
# Replace this with your ECS service’s internal DNS name or ALB DNS
ecs_endpoint = “http://your-internal-alb-dns-name”

# Send a GET request with your query
response = requests.get(
ecs_endpoint,
headers={“Content-Type”: “application/json”},
json={“query”: event.get(“query”, “”)},
timeout=5
)

if response.status_code == 200:
agent_response = response.json()
# Handle the response as needed
return {
“statusCode”: 200,
“body”: agent_response
}
else:
return {
“statusCode”: response.status_code,
“body”: “Error from ECS service”
}
except Exception as e:
print(f”Error: {str(e)}”)
return {
“statusCode”: 500,
“body”: f”Error connecting to ECS service: {str(e)}”
}

After receiving the response, your Lambda can process it accordingly—whether to store, display, or trigger further actions.

For a more reliable setup, consider adding error handling and retries. Set appropriate timeouts and use a service discovery mechanism or an ALB for consistent access points. Monitoring the connection’s health also helps ensure everything runs smoothly.

This method makes it possible for your Lambda function to interact with an agent in ECS and get responses back to continue your workflow efficiently.