{"id":265,"date":"2025-12-29T13:30:21","date_gmt":"2025-12-29T12:30:21","guid":{"rendered":"https:\/\/blog.ctr24.co.pl\/?p=265"},"modified":"2025-12-29T13:33:58","modified_gmt":"2025-12-29T12:33:58","slug":"celery-rabbitmq-jinja-env-do-wysylki-maili","status":"publish","type":"post","link":"https:\/\/blog.ctr24.co.pl\/?p=265","title":{"rendered":"Celery + RabbitMQ + Jinja + .env do wysy\u0142ki maili."},"content":{"rendered":"\n

Minimalny, dzia\u0142aj\u0105cy przyk\u0142ad, kt\u00f3ry mo\u017cna od razu uruchomi\u0107 na wielu workerach.<\/h2>\n\n\n
celery_mail_demo\/\r\n\u251c\u2500\u2500 celery_app.py\r\n\u251c\u2500\u2500 tasks.py\r\n\u251c\u2500\u2500 templates\/\r\n\u2502   \u2514\u2500\u2500 mail\/\r\n\u2502       \u2514\u2500\u2500 report.html\r\n\u251c\u2500\u2500 .env\r\n\u251c\u2500\u2500 requirements.txt\r\n\u2514\u2500\u2500 run_worker.sh\r\n<\/pre><\/div>\n\n\n
requirements.txt<\/p>\n\n\n
celery==5.3.1\r\njinja2\r\npython-dotenv\r\n<\/pre><\/div>\n\n\n
.env<\/p>\n\n\n
# RabbitMQ\r\nBROKER_URL=amqp:\/\/celery:secret@192.168.0.150:5672\/analysis\r\n\r\n# SMTP\r\nSMTP_HOST=smtp.example.com\r\nSMTP_PORT=587\r\nSMTP_USER=noreply@example.com\r\nSMTP_PASSWORD=SECRET\r\nSMTP_FROM=noreply@example.com\r\n<\/pre><\/div>\n\n\n
celery_app.py<\/p>\n\n\n
import os\r\nfrom celery import Celery\r\nfrom dotenv import load_dotenv\r\n\r\nload_dotenv()  # wczytuje .env\r\n\r\ncelery = Celery(\r\n    \"mail_demo\",\r\n    broker=os.environ[\"BROKER_URL\"],\r\n    backend=\"rpc:\/\/\"\r\n)\r\n<\/pre><\/div>\n\n\n
tasks.py<\/p>\n\n\n
import os\r\nfrom celery_app import celery\r\nfrom jinja2 import Environment, FileSystemLoader\r\nfrom email.message import EmailMessage\r\nimport smtplib\r\nfrom datetime import datetime\r\n\r\nBASE_DIR = os.path.dirname(os.path.abspath(__file__))\r\n\r\njinja_env = Environment(\r\n    loader=FileSystemLoader(os.path.join(BASE_DIR, \"templates\"))\r\n)\r\n\r\ndef _send_smtp(msg):\r\n    with smtplib.SMTP(os.environ[\"SMTP_HOST\"], int(os.environ[\"SMTP_PORT\"]), timeout=30) as smtp:\r\n        smtp.starttls()\r\n        smtp.login(os.environ[\"SMTP_USER\"], os.environ[\"SMTP_PASSWORD\"])\r\n        smtp.send_message(msg)\r\n\r\n@celery.task(bind=True, autoretry_for=(Exception,), retry_backoff=30, retry_kwargs={\"max_retries\": 3})\r\ndef send_report_mail(self, to, station, start, end, results):\r\n    template = jinja_env.get_template(\"mail\/report.html\")\r\n    html = template.render(\r\n        station=station,\r\n        start=start,\r\n        end=end,\r\n        results=results,\r\n        generated_at=datetime.utcnow().isoformat()\r\n    )\r\n\r\n    msg = EmailMessage()\r\n    msg[\"From\"] = os.environ[\"SMTP_FROM\"]\r\n    msg[\"To\"] = to\r\n    msg[\"Subject\"] = f\"Raport {station}\"\r\n\r\n    msg.set_content(\"Ten email zawiera raport HTML.\")\r\n    msg.add_alternative(html, subtype=\"html\")\r\n\r\n    _send_smtp(msg)\r\n<\/pre><\/div>\n\n\n
Szablon Jinja \u2013 templates\/mail\/report.html<\/p>\n\n\n
<!DOCTYPE html>\r\n<html>\r\n<head>\r\n    <meta charset=\"utf-8\">\r\n<\/head>\r\n<body>\r\n    <h2>Raport dla stacji {{ station }}<\/h2>\r\n    <p>Zakres: {{ start }} \u2013 {{ end }}<\/p>\r\n\r\n    <ul>\r\n        {% for key, value in results.items() %}\r\n            <li><b>{{ key }}<\/b>: {{ value }}<\/li>\r\n        {% endfor %}\r\n    <\/ul>\r\n\r\n    <p style=\"color: gray; font-size: 12px\">Wygenerowano: {{ generated_at }}<\/p>\r\n<\/body>\r\n<\/html>\r\n<\/pre><\/div>\n\n\n
Skrypt uruchamiaj\u0105cy worker \u2013 run_worker.sh<\/p>\n\n\n
#!\/bin\/bash\r\nsource venv\/bin\/activate\r\nexport $(cat .env | xargs)  # wczytuje zmienne \u015brodowiskowe z .env\r\ncelery -A celery_app.celery worker --loglevel=info --concurrency=2\r\n<\/pre><\/div>\n\n\n
Co MUSI by\u0107 na ka\u017cdym workerze<\/h2>\n\n\n\n
    \n
  1. Ten sam kod:<\/strong> celery_app.py + tasks.py<\/li>\n\n\n\n
  2. Szablony Jinja:<\/strong> templates\/mail\/report.html<\/li>\n\n\n\n
  3. .env<\/strong> (lub ENV w systemd)<\/li>\n\n\n\n
  4. Python + venv + dependencies<\/strong><\/li>\n\n\n\n
  5. Dost\u0119p do SMTP<\/strong> i RabbitMQ<\/strong><\/li>\n<\/ol>\n\n\n\n
    Uruchomienie workera<\/h2>\n\n\n
    pip install -r requirements.txt\n\nchmod +x run_worker.sh\n\n.\/run_worker.sh<\/pre><\/div>\n\n\n
    Przyk\u0142ad wywo\u0142ania zadania z Python (CLI)<\/h1>\n\n\n
    from tasks import send_report_mail\r\n\r\nsend_report_mail.delay(\r\n    to=\"user@example.com\",\r\n    station=\"ST001\",\r\n    start=\"2025-12-01\",\r\n    end=\"2025-12-29\",\r\n    results={\"temp_avg\": 23, \"humidity\": 70}\r\n)\r\n<\/pre><\/div>","protected":false},"excerpt":{"rendered":"
    Minimalny, dzia\u0142aj\u0105cy przyk\u0142ad, kt\u00f3ry mo\u017cna od razu uruchomi\u0107 na wielu workerach. requirements.txt .env celery_app.py tasks.py Szablon Jinja \u2013 templates\/mail\/report.html Skrypt<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1,6,19],"tags":[],"class_list":["post-265","post","type-post","status-publish","format-standard","hentry","category-bez-kategorii","category-python","category-tips"],"_links":{"self":[{"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/posts\/265","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=265"}],"version-history":[{"count":3,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/posts\/265\/revisions"}],"predecessor-version":[{"id":268,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=\/wp\/v2\/posts\/265\/revisions\/268"}],"wp:attachment":[{"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=265"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=265"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/blog.ctr24.co.pl\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=265"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}