Использование boto3 в lambda с клиентом SNS & EMR для получения сведений о кластере и отправки его на почту

Question

Я могу получить выходные данные и отправить их по электронной почте, используя службу SNS в приведенном ниже коде.Тем не менее, он отправляет почту для 1 вывода кластера за раз, а не отправляет все сведения о кластере в 1 письме.

import boto3 import json from datetime import timedelta

REGION = 'us-east-1 '

Topic_Arn = "arn: aws: sns: us-east-1: 000000: testlog"

emrclient = boto3.client (' emr ', region_name = REGION) snsclient= boto3.client ('sns', region_name = REGION)

def lambda_handler (событие, контекст): EMRS = emrclient.list_clusters (ClusterStates = ['STARTING', 'RUNNING', 'WAITING'])

clusters = EMRS["Clusters"]
for cluster_details in clusters :
    id = cluster_details.get("Id")

    describe_cluster = emrclient.describe_cluster(
        ClusterId = id
        )
    cluster_values = describe_cluster["Cluster"]
    name = cluster_values.get("Name")

    tag_val = cluster_values.get("Tags")
    Instancehours = cluster_values.get("NormalizedInstanceHours")


    emr_ig = emrclient.list_instance_groups(
     ClusterId = id
     )
    emrid = emr_ig["InstanceGroups"]
    for item in emrid :
        purchase_type = item.get("Market")
        instancegroup_id = item.get("Id")
        instancegroup_type = item.get("InstanceGroupType")
        status = item.get("Status")
        state = status.get("State")
        timeline = status.get("Timeline")
        autoscaling = item.get("AutoScalingPolicy", None)
        #autoscaling_status = autoscaling.get("Status")
        #autoscaling_state = autoscaling_status.get("State")
        create_date_time = timeline.get("CreationDateTime")
        ready_date_time = timeline.get("ReadyDateTime")
        emrdetails = "Cluster_ID = " + id + "," + "status_of_cluster = " + state + "," + " Instance_Group = " + instancegroup_type + "," + " Market = " + purchase_type + "," + " CreationDateTime = " + str(create_date_time) + "," + " NormalizedInstanceHours = " + str(Instancehours) + "," + " Autosacle = " + str(autoscaling)
        emr_status_list = []
        emr_status_list.append(emrdetails)

        emrStatusCheck = []
        for emr_status in emr_status_list :
            if ((emr_status.split(",")[3]).split("=")[1].strip() == str("ON_DEMAND") and (emr_status.split(",")[2]).split("=")[1].strip() == str("CORE") and (emr_status.split(",")[6]).split("=")[1].strip() == str("None")):
                emrStatusCheck.append(emr_status)
                print(emrStatusCheck)

                  snsclient.publish(
                      TopicArn =  Topic_Arn,
                      Subject = "EMR Cluster Details",
                      Message = emrStatusCheck
                      )

Answer 1

Да, переместить оператор публикации SNS за пределы цикла.Вам также может понадобиться объединить сообщения для каждого кластера в одно составное сообщение

Answer 2

Переместите оператор sns из цикла for, чтобы он выполнялся только один раз.Пример:

for emr_status in emr_status_list :
    if ((emr_status.split(",")[3]).split("=")[1].strip() == str("ON_DEMAND") and (emr_status.split(",")[2]).split("=")[1].strip() == str("CORE") and (emr_status.split(",")[6]).split("=")[1].strip() == str("None")): 

        emrStatusCheck.append(emr_status) 
        print(emrStatusCheck) 
snsclient.publish( TopicArn = Topic_Arn, Subject = "EMR Cluster Details", Message = emrStatusCheck )