Looker × SendGrid で複数の宛先へメール送信を実装する方法と、活用方法

def action_list(request):
  """Return action hub list endpoint data for action"""
  auth = authenticate(request)
  if auth.status_code != 200:
    return auth

  response = {
    'label': 'SendGrid email promo',
    'integrations': [{
      'name': 'メール配信',
      'label': 'メール配信',
      'supported_action_types': ['query'],
      "icon_data_uri": icon_data_uri,
      'form_url': BASE_DOMAIN + 'form',
      'url': BASE_DOMAIN + 'execute',
      'supported_formats': ['json'],
      'supported_formattings': ['formatted'],
      'supported_visualization_formattings': ['noapply'],
      'params': [
        {'name': 'email', 'label': 'Email',
          'user_attribute_name': 'email', 'required': True},
        {'name': 'user_id', 'label': 'User ID',
          'user_attribute_name': 'id', 'required': True}
      ]
    }]
  }

  return Response(json.dumps(response), status=200, mimetype='application/json')

def action_form(request):
    """Return form endpoint data for action"""
    auth = authenticate(request)
    if auth.status_code != 200:
        return auth
    
    # Define the form fields with drop-down options
    response = [{
        'name': 'promotion',
        'label': 'プロモーションタイプ',
        'description': 'プロモーションタイプを選択してください',
        'type': 'select',
        'required': True,
        "default":  default_type,
        'options': [{'name': '期間限定クーポン', 'label': '期間限定クーポンの配布用'},
                    {'name': 'カート放棄', 'label': 'カート放棄顧客へのアプローチ'}],
        'interactive': True  # dynamic field for model specific options
    }]

if ('promotion' in form_params):
    if (form_params['promotion'] == '期間限定クーポン'):
        response.extend([{
                'name': 'title',
                'label': '期間限定クーポンの配布用：タイトル',
                'description': '顧客向け案内メールのタイトル',
                'type': 'textarea',
                'required': True,
                'default': limited_time_tilte,
            },
            {
                'name': 'body',
                'label': '期間限定クーポンの配布用：本文',
                'description': '顧客向け案内メールの本文',
                'type': 'textarea',
                'required': True,
                'default': limited_time_body,
            }])
    elif (form_params['promotion'] == '期間限定クーポン'):
        response.extend([{
                'name': 'title',
                'label': 'カート放棄：タイトル',
                'description': '顧客向け案内メールのタイトル',
                'type': 'textarea',
                'required': True,
                'default': cart_abandonment_title,
            },
            {
                'name': 'body',
                'label': 'カート放棄：本文',
                'description': '顧客向け案内メールの本文',
                'type': 'textarea',
                'required': True,
                'default': cart_abandonment_body,
            }])

def action_execute(request):
    """Generate a response from Generative AI Studio from a Looker action"""
    request_json = request.get_json()
    attachment = request_json['attachment']
    # Load data from attachment
    all_data = sanitize_and_load_json_str(attachment['data'])

    # アドレス・氏名を取得する
    emails_with_names = {}
    for item in all_data:
        email = item["users.email"]
        first_name = item.get("users.first_name", "お客")  # デフォルト値を設定
        last_name = item.get("users.last_name", "")  # デフォルト値を設定
        if email not in emails_with_names:
            emails_with_names[email] = {"first_name": first_name, "last_name": last_name}

    form_params = request_json['form_params']
    # Extract necessary parameters from form
    title = form_params.get('title', "")
    body = form_params.get('body', "")

    # for 文でメール送信する    
    for email, name_data in emails_with_names.items():
        html_content = f"{name_data['first_name']} {name_data['last_name']} 様 \\n" + body
        client = sendgrid.SendGridAPIClient(os.environ.get('SENDGRID_API_KEY'))
        message = sendgrid.Mail(
            from_email=os.environ.get('EMAIL_SENDER'),
            to_emails=[email],
            subject=title,
            html_content=html_content
        )
        client.send(message)