DataWorks:Use a PyODPS node to send emails

Step 1: Create an exclusive resource group

1. Log on to the DataWorks console. In the top navigation bar, select the target region. In the left-side navigation pane, click Resource Group.

2. On the Exclusive Resource Groups tab, click Create Resource Group.

3. Configure the resource group parameters. For details, see Create and use a serverless resource group.

   Important

   The resource group must be in the same region as your DataWorks workspace.

4. Click Buy Now.

Step 2: Associate the resource group with a workspace

1. Find the resource group you created and click Associate Workspace in the Actions column.

2. In the Associate Workspace panel, find your workspace and click Associate in the Actions column.

Step 3: Open DataStudio

Log on to the DataWorks console. In the top navigation bar, select the target region. In the left-side navigation pane, choose Data Development and O&M > Data Development. Select your workspace from the drop-down list and click Go to Data Development.

Step 4: Create a PyODPS 2 node

1. On the DataStudio page, hover over the icon and choose Create Node > MaxCompute > PyODPS 2. Alternatively, click the workflow name in the Business Flow section, right-click MaxCompute, and choose Create Node > PyODPS 2.

2. In the Create Node dialog box, set the Name and Path parameters.

   Note

   The node name can be up to 128 characters and can contain letters, digits, underscores (_), and periods (.).

3. Click Confirm.

4. On the node configuration tab, enter your email-sending code. Replace the placeholders in the table below with your actual values before running. Option 1: Port 465 (SMTP over SSL) — recommended Use this option when your email provider supports SSL on port 465.

   Placeholder	Description	Example
   <yourHost>	SMTP server address of your email service	smtp.example.com
   <yourUserName>	Username for authenticating with the mail server	user@example.com
   <yourPassWord>	Password for the mail server account	—
   <senderAddress>	Sender email address	sender@example.com
   <receiverAddress>	Recipient email address	recipient@example.com

   import smtplib
   from email.mime.text import MIMEText
   from odps import ODPS
   
   mail_host = '<yourHost>'
   mail_username = '<yourUserName>'
   mail_password = '<yourPassWord>'
   mail_sender = '<senderAddress>'
   mail_receivers = ['<receiverAddress>']
   
   # Read query results and build email body
   mail_content = ''
   with o.execute_sql('query_sql').open_reader() as reader:
       for record in reader:
           mail_content += str(record['column_name']) + ' ' + record['column_name'] + '\n'
   
   message = MIMEText(mail_content, 'plain', 'utf-8')
   message['Subject'] = 'mail test'
   message['From'] = mail_sender
   message['To'] = mail_receivers[0]
   
   try:
       # Connect using SSL on port 465
       smtpObj = smtplib.SMTP_SSL(mail_host + ':465')
       smtpObj.login(mail_username, mail_password)
       smtpObj.sendmail(mail_sender, mail_receivers, message.as_string())
       smtpObj.quit()
       print('mail send success')
   except smtplib.SMTPException as e:
       print('mail send error', e)

   Option 2: Port 587 (SMTP with STARTTLS) Use this option when your email provider requires STARTTLS on port 587.

   import smtplib
   from email.mime.text import MIMEText
   from odps import ODPS
   
   mail_host = '<yourHost>'
   mail_username = '<yourUserName>'
   mail_password = '<yourPassWord>'
   mail_sender = '<senderAddress>'
   mail_receivers = ['<receiverAddress>']
   
   # Read query results and build email body
   mail_content = ''
   with o.execute_sql('query_sql').open_reader() as reader:
       for record in reader:
           mail_content += str(record['column_name']) + ' ' + record['column_name'] + '\n'
   
   message = MIMEText(mail_content, 'plain', 'utf-8')
   message['Subject'] = 'mail test'
   message['From'] = mail_sender
   message['To'] = mail_receivers[0]
   
   try:
       # Connect and upgrade to TLS on port 587
       smtpObj = smtplib.SMTP()
       smtpObj.connect(mail_host, 587)
       smtpObj.ehlo()
       smtpObj.starttls()
       smtpObj.login(mail_username, mail_password)
       smtpObj.sendmail(mail_sender, mail_receivers, message.as_string())
       smtpObj.quit()
       print('mail send success')
   except smtplib.SMTPException as e:
       print('mail send error', e)

5. Click the icon in the top toolbar to save the node.

Step 5: Commit the node

1. Click the icon in the top toolbar.

2. In the Submit dialog box, enter a description in the Change description field.

3. Click Confirm.

If your workspace is in standard mode, click Deploy in the upper-right corner after committing to deploy the node. For details, see Deploy nodes.

Step 6: Switch the node to the exclusive resource group

1. In the upper-right corner of the node configuration tab, click Operation Center.

2. In the left-side navigation pane of Operation Center, choose Auto Triggered Node O&M > Auto Triggered Nodes.

3. Find the node, then in the Actions column choose More > Modify Scheduling Resource Group.

4. In the Modify Scheduling Resource Group dialog box, select the exclusive resource group from the New Resource Group drop-down list.

5. Click OK.

Step 7: Test the node

Run the node to verify that the email is delivered. For details, see View and manage auto triggered tasks.