Hantera Firehose delivery streams
Dataingenjörsarbete innebär ibland att hantera behörigheter och användare – och att använda grafiska verktyg i stället för skript. I den här kursen visar vi hur du använder boto3 för att arbeta med Kinesis och Lambda, men också hur du utför vissa åtgärder direkt i AWS.
Under hela kursen sköts AWS-åtgärderna åt dig, så att du kan fokusera på programmeringsaspekterna.
Skärminspelningarna finns här för att ge dig en fullständig bild av hur allt fungerar. Du är välkommen att prova åtgärderna i AWS på egen hand, men det är helt frivilligt:
- Du kommer inte att testas på AWS-plattformen
- AWS-åtgärderna hanteras åt dig under hela kursen, så vi rekommenderar starkt att du fokuserar på att slutföra kursen först
- Om du någon gång väljer att prova saker i AWS, se till att alltid stoppa dina instanser när du är klar – annars kan du få en oväntat hög faktura
Nu börjar du lära dig hur du interagerar med Firehose-strömmar. Din föregångare har skapat några Firehose-strömmar, och du vill ta bort dem alla för att börja med ett rent konto.
Låt oss göra en nystart i stadens AWS-konto!
Den här övningen är en del av kursen
Strömdata med AWS Kinesis och Lambda
Övningsinstruktioner
- Importera boto3 och skapa en boto3 Firehose-klient.
- Hämta listan över Firehose Delivery streams.
- Iterera över svarsinnehållet och ta bort varje ström.
- Kontrollera att alla delivery streams har tagits bort genom att skriva ut resultatet av
.list_delivery_streams().
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# 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.____())