Керування потоками доставки Firehose
Інженерія даних інколи передбачає керування дозволами, користувачами та використання інтерфейсу замість скриптів. У цьому курсі ми покажемо, як працювати з boto3 для Kinesis і Lambda, а також як виконувати окремі операції в AWS.
Протягом усього курсу операції в AWS виконуються за вас, щоб ви могли зосередитися на програмуванні.
Скринкасти дають повний контекст, як усе працює. Можете самостійно спробувати ці дії в AWS — це необов'язково:
- Вас не перевірятимуть на платформі AWS
- Операції в AWS виконуються за вас упродовж курсу, тож ми радимо спершу зосередитися на проходженні курсу
- Якщо вирішите спробувати AWS, завжди зупиняйте свої інстанси, щойно закінчите роботу, інакше отримаєте чималий рахунок
А зараз ви починаєте навчатися взаємодії з потоками Firehose. Ваш(а) попередник(ця) створив(ла) кілька потоків Firehose, і ви хочете видалити їх усі, щоб почати з чистого аркуша в обліковому записі.
Зробімо свіжий старт в міському обліковому записі AWS!
Ця вправа є частиною курсу
Потокові дані з AWS Kinesis і Lambda
Інструкції до вправи
- Імпортуйте boto3 та створіть клієнт boto3 для Firehose.
- Отримайте список потоків доставки Firehose.
- Проітеруйте вміст відповіді та видаліть кожен потік.
- Переконайтеся, що всі потоки доставки видалено, вивівши результат
.list_delivery_streams().
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Import boto3 and create boto3 Firehose client
import ____
firehose = boto3.____('____',
aws_access_key_id=AWS_KEY_ID, aws_secret_access_key=AWS_SECRET,
region_name='us-east-1', endpoint_url=endpoints['FIREHOSE'])
# Get list of delivery streams
response = firehose.____()
# Iterate over the response contents and delete every stream
for stream_name in response['DeliveryStreamNames']:
firehose.____(DeliveryStreamName=stream_name)
print(f"Deleted stream: {stream_name}")
# Print list of delivery streams
print(firehose.____())