使用 Python 和 Airflow 在电子邮件中发送 Redshift 查询结果答案

【问题标题】：Sending Redshift Query Result in Email with Python and Airflow使用 Python 和 Airflow 在电子邮件中发送 Redshift 查询结果
【发布时间】：2021-08-29 13:35:03
【问题描述】：

我正在制作每日 DAG，它将在 Redshift 中运行查询并将结果表通过电子邮件发送。

我目前设法获取查询结果并将其放入 DataFrame。我的问题是使用send_email（来自气流包）并为其选择参数以显示数据。

不幸的是，电子邮件的输出不是表格，只是结果以文本形式到处都是。

这是我为send_email 写的：

        html_content = f"""
                        <html><body><p>Hello,</p>
                        <p>Found {num_of_late_dags} Late DAGs:</p>
                        {late_dags}
                        <p>Regards,</p>
                        <p>Me</p>
                        </body></html>
                        """
        send_email(to=v_email_recipients_daily_report,
                   cc=cc,
                   bcc=bcc,
                   subject=f'Daily DAG Load Report',
                   html_content=html_content,
                   mime_subtype='alternative') ```

【问题讨论】：

你试过df.to_html() 吗？ pandas.pydata.org/docs/reference/api/…
谢谢！我用过，但显然我用错了。现在工作。非常感谢！

标签： html email amazon-redshift airflow

【解决方案1】：

更新：

我在.format(to_html()) 中的html_content 之后使用了pd.to_html()，但这没有用。在将数据创建为有效的 DataFrame 时，我使用了 to_html()。不知道为什么，他们应该这样做。

所以它看起来像这样：df = pd.DataFrame(data, columns=['X',Y']).to_html()

然后将df 放入 HTML 内容中就可以了。

【讨论】：