在DataWorks中通过函数计算节点发送邮件

使用限制

DataWorks目前仅支持华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华南1（深圳）、西南1（成都）、中国香港、新加坡、马来西亚（吉隆坡）、印度尼西亚（雅加达）、德国（法兰克福）、英国（伦敦）、美国（硅谷）、美国（弗吉尼亚）地域的工作空间使用函数计算功能。

步骤一：创建事件函数

1. 登录函数计算3.0控制台，控制台左上角显示函数计算 FC 3.0时，表示当前控制台为3.0控制台，如果您登录的是函数计算 2.0的控制台，请点击右上角的体验函数计算 3.0进行切换。

2. 在左侧导航栏，单击函数，在顶部导航栏切换至目标地域，在函数页面单击创建函数。

3. 选择事件函数，在函数代码区域，运行环境选择Python 3.10，代码上传方式选择使用示例代码。更多配置详情可参见创建事件函数。

4. 单击创建，在函数详情页签的代码页面编辑index.py，输入发送邮件的业务逻辑代码，示例代码如下：

   重要

   • 以下示例代码中的mail_host、mail_port、mail_username、mail_password、mail_sender、mail_receivers参数请根据实际情况设置。

   • 电子邮件的账号必须开启SMTP服务。某些电子邮件服务提供商默认未开启，需自行检查并开启。例如：163邮箱默认就未开启SMTP服务。

   • 某些电子邮件服务提供商基于安全原因，可能会使用一种类似授权码的专用密码，用于三方邮件客户端进行登录。这时mail_password需设置为授权码而不是账号密码。例如：163邮箱就存在授权码，且三方登录时必须使用授权码来作为密码登录。

   # -*- coding: utf-8 -*-
   import logging
   import json
   import smtplib
   from email.mime.text import MIMEText
   
   def handler(event, context):
     evts = json.loads(event)
   
     logger = logging.getLogger()
     logger.info('event: %s', evts)
     mail_host = 'smtp.163.com'                 ## 邮箱服务地址
     mail_port = '465';                         ## 邮箱smtp协议端口号
     mail_username = 'sender_****@163.com'      ## 登录用户名
     mail_password = 'EWEL******KRU'            ## 登录用户密码
     mail_sender = 'sender_****@163.com'        ## 发件人邮箱地址
     mail_receivers = ['receiver_****@163.com'] ## 收件人邮箱地址
   
     mail_content=generate_mail_content(evts)
     message = MIMEText(mail_content,'plain','utf-8')
     message['Subject'] = 'mail test'
     message['From'] = mail_sender
     message['To'] = mail_receivers[0]
     smtpObj = smtplib.SMTP_SSL(mail_host + ':' + mail_port)
     smtpObj.login(mail_username,mail_password)
     smtpObj.sendmail(mail_sender,mail_receivers,message.as_string())
     smtpObj.quit()
     return 'mail send success'
   
   def generate_mail_content(evt):
     mail_content=''
     if 'msg' in evt.keys():
         mail_content=evt['msg']
     else:
         logger = logging.getLogger()
         logger.error('msg not present in event')
     '''
     此处可增加处理邮件内容读取逻辑
     '''
     return mail_content

5. 单击部署代码按钮。

步骤二：（可选）测试函数

通过配置创建新测试事件参数，模拟测试。

1. 在函数详情页面的代码页签，单击测试函数右侧的图标，从下拉列表中，选择配置测试参数。

   在配置测试参数面板，选择创建新测试事件或编辑已有测试事件，输入参数，点击确定。

   

   事件内容输入：

   {
       "msg": "This is a test message"
   }

2. 单击测试函数即可完成测试。

   

3. 检查收件人的邮箱中是否收到邮件。

   说明

   某些电子邮件服务器可能会将未知发件人识别为垃圾邮件从而进行拦截，因此若您未在收件箱中找到测试邮件，则需到垃圾邮件中进行查找。

步骤三：在DataWorks中创建并配置函数计算节点

1. 登录DataWorks控制台，单击左侧导航栏中的工作空间。

2. 将页面顶部导航栏的地域列表切换为步骤一：创建事件函数中指定的地域。

3. 在工作空间列表中单击目标工作空间名称，进入工作空间详情页面。若您在当前地域下无工作空间，则需创建一个工作空间，详情可参见创建工作空间。

4. 单击左侧导航栏中的数据开发与治理下的数据开发，进入DataWorks数据开发页面。

5. 单击目标业务流程名称，在其展开的通用节点上右键单击并选择函数计算。在创建节点弹出框中输入节点名称并单击确定按钮，完成函数计算节点的创建。

   

6. 设置函数计算节点参数。

   

   参数	描述
   选择函数	选择步骤一：创建事件函数的函数名称。
   选择版本或别名	选择调用函数时所使用的版本或别名，默认版本为LATEST。更多请见版本管理和别名管理。
   调用方式	本文选择同步。调用方式详情可参见同步调用、异步调用。
   变量	调用函数的参数。本文示例如下： { "msg": "This is a test message from dataworks!" }

7. （可选）调试函数计算节点。节点配置完成后，您可单击图标，为代码变量赋值常量进行调试运行，测试节点代码逻辑是否正确。

8. 配置节点的周期调度属性。DataWorks提供的调度参数，可实现调度场景下代码动态传参。打开右侧的调度配置，在参数区域设置参数。更多调度参数的配置，请参见调度参数支持的格式。更多调度属性，请参见任务调度属性配置概述。