在我的aws账户中,我有一个针对我的SQS用户的ASG设置。最小容量为3,最大容量为8,销毁策略设置为默认。它有两个简单的伸缩策略,附加到监控SQS队列大小的云监控告警上。 这是云手表警报ApproximateNumberOfMessagesVisible >= 10 for 1 consecutive periods of 300 seconds for the metric dimensions的阈值。 当云监控告警状态在300秒后为“报警”时,ASG会添加1个实例,直到达到最大容量。同样,当云监控警报状态在300秒后为"ok“时,ASG将删除1个实例,直到达到最小容量。
我在lambda中使用以下代码连接到ES域:
host = os.environ['esDomain']
print("ES DOMAIN IS..........")
region = os.environ['AWS_REGION']
service = 'es'
credentials = boto3.Session().get_credentials()
def connectES():
print('Connecting to the ES Endpoint {0}')
awsauth