Skip to content

Attributes

Classes

spark_expectations.notifications.plugins.email.SparkExpectationsEmailPluginImpl

Bases: SparkExpectationsNotification

This class implements/supports functionality to send email

Functions

send_notification(_context: SparkExpectationsContext, _config_args: Dict[Union[str], Union[str, bool]]) -> None

function to send email notification for requested mail id's Args: _context: object of SparkExpectationsContext _config_args: dict(which consist to: receiver mail(str), subject: subject of the mail(str) and body: body of the mail(str) Returns:

Source code in spark_expectations/notifications/plugins/email.py 
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
@spark_expectations_notification_impl
def send_notification(
    self,
    _context: SparkExpectationsContext,
    _config_args: Dict[Union[str], Union[str, bool]],
) -> None:
    """
    function to send email notification for requested mail id's
    Args:
        _context: object of SparkExpectationsContext
        _config_args: dict(which consist to: receiver mail(str), subject: subject of
                      the mail(str) and body: body of the mail(str)
    Returns:

    """
    try:
        if _context.get_enable_mail is True:
            msg = MIMEMultipart()
            msg["From"] = _context.get_mail_from
            msg["To"] = _context.get_to_mail
            msg["Subject"] = _context.get_mail_subject

            # body = _config_args.get('mail_body')

            mail_content = f"""{_config_args.get("message")}"""
            msg.attach(MIMEText(mail_content, "plain"))

            # mailhost.com
            server = smtplib.SMTP(
                _context.get_mail_smtp_server, _context.get_mail_smtp_port
            )
            server.starttls()
            text = msg.as_string()
            server.sendmail(_context.get_mail_from, _context.get_to_mail, text)
            server.quit()

            _log.info("email send successfully")

    except Exception as e:
        raise SparkExpectationsEmailException(
            f"error occurred while sending email notification from spark expectations project {e}"
        )