Studium przypadku: Budowanie systemu powiadomień

Wprowadzenie do AWS Boto w Pythonie

Maksim Pecherskiy

Data Engineer

Produkt końcowy

Budowanie systemu powiadomień

Konfiguracja tematu

Utwórz temat
Pobierz plik CSV z listą kontaktów
Utwórz tematy dla każdej usługi
Subskrybuj kontakty do odpowiednich tematów

Budowanie systemu powiadomień

Pobierz zagregowane dane

Pobierz miesięczny raport
Pobierz liczbę dziur w jezdni
Pobierz liczbę zgłoszeń nielegalnego wysypiska

Wyślij alerty

Jeśli liczba dziur przekracza 100, wyślij alert
Jeśli liczba wysypisk przekracza 30, wyślij alert

Konfiguracja tematu

Inicjalizacja klienta SNS

sns = boto3.client('sns', 
                   region_name='us-east-1',
                   aws_access_key_id=AWS_KEY_ID, 
                   aws_secret_access_key=AWS_SECRET)

Utwórz tematy i zapisz ich ARN

trash_arn = sns.create_topic(Name="trash_notifications")['TopicArn']
streets_arn = sns.create_topic(Name="streets_notifications")['TopicArn']

Konfiguracja tematu

Subskrybowanie użytkowników do tematów

contacts = pd.read_csv('http://gid-staging.contacts.csv')

Subskrybowanie użytkowników do tematów

contacts.csv

Name	Email	Phone	Department
John Smith	[email protected]	+11224567890	trash
Fanny Mae	[email protected]	+11234597890	trash
Janessa Goldsmith	[email protected]	+11534567890	streets
Evelyn Monroe	[email protected]	+11234067890	streets
Max Pe	[email protected]	+11234517890	streets

Subskrybowanie użytkowników do tematów

Utwórz metodę subscribe_user

def subscribe_user(user_row):

    if user_row['Department'] == 'trash':
        sns.subscribe(TopicArn = trash_arn, Protocol='sms', Endpoint=str(user_row['Phone']))
        sns.subscribe(TopicArn = trash_arn, Protocol='email', Endpoint=user_row['Email'])

    else:
        sns.subscribe(TopicArn = streets_arn, Protocol='sms', Endpoint=str(user_row['Phone']))
        sns.subscribe(TopicArn = streets_arn, Protocol='email', Endpoint=user_row['Email'])

Zastosuj metodę subscribe_user do każdego wiersza

contacts.apply(subscribe_user, axis=1)

Subskrybowanie użytkowników do tematów

Subskrybowanie użytkowników do tematu

Pobierz zagregowane dane

Wczytaj raport styczniowy do DataFrame

df = pd.read_csv('http://gid-reports.2019/feb/final_report.csv')

Pobierz zagregowane dane

service_name	count
Illegal Dumping	2580
Potential Missed Collection	150
Pothole	1170
Traffic Sign - Maintain	210
Traffic Signal Head Turned	60
Traffic Signal Light Out	120

Pobierz zagregowane dane

Ustaw indeks, aby uzyskać dostęp do liczb według nazwy usługi

df.set_index('service_name', inplace=True)

Pobierz zagregowane dane

trash_violations_count = df.at['Illegal Dumping', 'count']
streets_violations_count = df.at['Pothole', 'count']

Wyślij alerty

if trash_violations_count > 100:

  # Construct the message to send
    message = "Trash violations count is now {}".format(trash_violations_count)

    # Send message
    sns.publish(TopicArn = trash_arn, 
                Message = message, 
                Subject = "Trash Alert")

Wyślij alerty

if streets_violations_count > 30:

    # Construct the message to send
    message = "Streets violations count is now {}".format(streets_violations_count)

    # Send message
    sns.publish(TopicArn = streets_arn, 
                Message = message, 
                Subject = "Streets Alert")

Wynik końcowy

Czas na ćwiczenia!

Wprowadzenie do AWS Boto w Pythonie