我正在寻找以编程方式安排 lambda 函数与另一个 lambda 函数一起运行一次的能力。例如，我使用date 和time 参数向myFirstFunction 发出请求，然后在那个日期和时间让mySecondFunction 执行。这是否仅适用于无状态 AWS 服务？我试图避免永远在线的 ec2 实例。
我发现调度 lambda 函数的大部分结果都与 cloudwatch 和定期安排的事件有关，而不是临时事件。
【问题讨论】：
标签： amazon-web-services aws-lambda
这是aws step functions 的完美用例。
使用Wait 状态和SecondsPath 或TimestampPath 在执行下一个状态之前添加所需的延迟。
【讨论】：
您想要做的事情（从 Lambda 调度 Lambda）使用当前的 AWS 服务是不可能的。
因此，为了避免永远在线的 ec2 实例，还有其他选择：
1) 使用 AWS 默认或自定义指标。例如，您可以使用ApproximateNumberOfMessagesVisible 或CPUUtilization（如果您的应用程序在处理请求时触发大量 CPU 使用）。您还可以创建自定义指标并在您的实例空闲时触发它（取决于您的实例中运行的应用程序）。
此选项的问题是您会浪费已付费的分钟数（AWS 总是按一小时收费，无论您是否使用实例 15 分钟）。
2) 在我看来，更好的选择是每分钟运行一次 Lambda 函数来检查您的实例是否处于空闲状态，并仅在它们接近整小时时关闭它们。
import boto3
from datetime import datetime
def lambda_handler(event, context):
print('ManageInstances function executed.')
environments = [['instance-id-1', 'SQS-queue-url-1'], ['instance-id-2', 'SQS-queue-url-2'], ...]
ec2_client = boto3.client('ec2')
for environment in environments:
instance_id = environment[0]
queue_url = environment[1]
print 'Instance:', instance_id
print 'Queue:', queue_url
rsp = ec2_client.describe_instances(InstanceIds=[instance_id])
if rsp:
status = rsp['Reservations'][0]['Instances'][0]
if status['State']['Name'] == 'running':
current_time = datetime.now()
diff = current_time - status['LaunchTime'].replace(tzinfo=None)
total_minutes = divmod(diff.total_seconds(), 60)[0]
minutes_to_complete_hour = 60 - divmod(total_minutes, 60)[1]
print 'Started time:', status['LaunchTime']
print 'Current time:', str(current_time)
print 'Minutes passed:', total_minutes
print 'Minutes to reach a full hour:', minutes_to_complete_hour
if(minutes_to_complete_hour <= 2):
sqs_client = boto3.client('sqs')
response = sqs_client.get_queue_attributes(QueueUrl=queue_url, AttributeNames=['All'])
messages_in_flight = int(response['Attributes']['ApproximateNumberOfMessagesNotVisible'])
messages_available = int(response['Attributes']['ApproximateNumberOfMessages'])
print 'Messages in flight:', messages_in_flight
print 'Messages available:', messages_available
if(messages_in_flight + messages_available == 0):
ec2_resource = boto3.resource('ec2')
instance = ec2_resource.Instance(instance_id)
instance.stop()
print('Stopping instance.')
else:
print('Status was not running. Nothing is done.')
else:
print('Problem while describing instance.')
【讨论】：
更新 - 我不建议使用这种方法。当 TTL 删除发生并且它们不接近 TTL 时间时，情况发生了变化。唯一的保证是该项目将在 TTL 之后被删除。感谢@Mentor 强调这一点。
2 个月前，AWS 宣布了 DynamoDB 项目 TTL，它允许您插入项目并在您希望将其删除时进行标记。到时候会自动删除。
您可以将此功能与 DynamoDB Streams 结合使用来实现您的目标 - 您的第一个函数将一个项目插入到 DynamoDB 表中。记录 TTL 应该在您希望触发第二个 lambda 时。设置一个触发您的第二个 lambda 的流。在此 lambda 中，您将识别删除事件，如果这是删除，则运行您的逻辑。
加分项 - 您可以使用表格项作为第一个 lambda 向第二个 lambda 传递参数的机制。
关于 DynamoDB TTL： https://aws.amazon.com/blogs/aws/new-manage-dynamodb-items-using-time-to-live-ttl/
【讨论】：
这确实取决于您的用例，但是您想在以后触发某些东西的想法是一种常见的模式。我做无服务器的方式是我有一个反应应用程序，它触发一个动作来存储未来的日期。我采用像 24-12-2020 这样的日期格式，然后使用 date() 对其进行转换，研究了提到的日期格式是正确的，所以我可能会尝试 12-24-2020 看看我得到了什么（！）。当我高兴时，我将它转换为 javascript React 中的 Unix 数字，我使用以下代码：
new Date(action.data).getTime() / 1000
其中 action.data 是日期，也可能是动作的时间。
我在 Amplify（无服务器）中运行 React，并将其存储到 dynamodb（无服务器）。然后我运行一个 Lambda 函数（无服务器）来检查我的 dynamodb 是否有任何日期（我现在实际上使用 Unix 时间）并时不时地比较两个 Unix 日期（存储），这两个日期都是数字，所以比较很容易。在我看来，这非常简单且非常可靠。
我只是根据所需的大致频率将 Lambda 上的 crontab 设置为所需的任何值，在大多数情况下，每五分钟运行一次 lambda 是相当不错的，尽管如果我只是在某个时区为企业运行它工作日应用程序我会控制 Lambda 多一点。 Lambda 对每月前 100 万个函数是免费的，并且每隔几分钟运行一次也不会产生任何费用。显然情况会发生变化，因此您需要在您所在的地区进行查找。
在这种情况下，您永远无法获得完美的时机。但是，对于绝大多数用例来说，它会根据 Lambda 函数的时间设置足够接近，您可以将其设置为每分钟检查一次或每天仅检查一次，这完全取决于您的应用程序。
或者，如果我想对事件做出即时反应，我可能会使用 SMS、SQS 或 Kinesis 即时流式传输消息，这完全取决于您的使用案例。
【讨论】：
我会选择在 myFirstFunction 中使用 message timers 将延迟工作排入 SQS。
目前，您不能将 SQS 用作 Lambda 事件源，但您可以定期安排 mySecondFunction 通过安排的 CloudWatch 事件（有点类似于您找到的其他选项的变体）检查队列，或者使用 CloudWatch ApproximateNumberOfMessagesVisible 上的警报以将 SNS 消息发送到 Lambda，并避免对经常长时间不活动的队列进行持续轮询。
【讨论】：