معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

Publish Airflow notification errors to SNS Topic

ویژگی	مقدار
سیستم عامل	-
نام فایل	cog-airflow-notify-sns-0.0.1
نام	cog-airflow-notify-sns
نسخه کتابخانه	0.0.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Cognitivo.ai
ایمیل نویسنده	engenharia@cognitivo.ai
آدرس صفحه اصلی	https://github.com/cognitivo/cog.dataplatform.service.system.airflow.notification
آدرس اینترنتی	https://pypi.org/project/cog-airflow-notify-sns/
مجوز	-

[![Python 3.7](https://img.shields.io/badge/python-3.7-blue.svg)](https://www.python.org/downloads/release/python-370/) [![PyPI version](https://badge.fury.io/py/publish-event-sns.svg)](https://badge.fury.io/py/airflow-notity-sns) [![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT) [![Twitter Follow](https://img.shields.io/twitter/follow/msantino.svg?style=social&label=Follow)](https://twitter.com/msantino) # Publish Airflow Notification to a SNS Topic This package adds a callback function to use in failures to DAGs and Tasks in a Airflow project. ## Installation ```bash pip install git+https://github.com/cognitivo/cog.dataplatform.service.system.airflow.notification.git ``` ## Usage ```python from datetime import timedelta # Airflow native imports to create a DAG from airflow import DAG, utils from airflow.operators.bash_operator import BashOperator # Here is function import from airflow_notify_sns import airflow_notify_sns # Dag Definition dag = DAG( dag_id='test_dag', default_args={ 'owner': 'Cognitivo.ai', 'depends_on_past': False, 'start_date': utils.dates.days_ago(1), 'retries': 3, 'retry_delay': timedelta(minutes=5) }, schedule_interval="@daily", dagrun_timeout=timedelta(minutes=60), sla_miss_callback=airflow_notify_sns #here ) # Add your tasks here t = BashOperator( dag=dag, task_id='test_env', bash_command='/tmp/test.sh', env={'EXECUTION_DATE': '{{ ds }}'}, on_failure_callback=airflow_notify_sns #here ) ``` When DAG or tasks ends in error, a notification will be send to a SNS Topic using AWS default connection (`aws_default`). ## Required Variable This module will try to find a variable named `airflow_notify_sns_arn` in your Airflow environment, containing SNS Topic ARN where message will be published to. If variable is not found, function will abort execution with no error.

نحوه نصب

نصب پکیج whl cog-airflow-notify-sns-0.0.1:

pip install cog-airflow-notify-sns-0.0.1.whl

نصب پکیج tar.gz cog-airflow-notify-sns-0.0.1:

pip install cog-airflow-notify-sns-0.0.1.tar.gz