Firehose-delivery streams beheren
Data engineering betekent soms dat je rechten en gebruikers beheert, en daarvoor GUI-tools gebruikt in plaats van scripts. In deze cursus laten we je zien hoe je met boto3 Kinesis en Lambda gebruikt, maar ook hoe je bepaalde handelingen op AWS uitvoert.
Door de hele cursus heen worden de handelingen op AWS voor je geregeld, zodat jij je kunt focussen op het programmeerwerk.
De screencasts geven je volledige context over hoe alles werkt. Voel je vrij om deze handelingen zelf op AWS uit te proberen, maar dit is volledig optioneel:
- Je wordt niet getoetst op het AWS-platform
- De AWS-handelingen worden in de hele cursus voor je geregeld, dus we raden je sterk aan om je eerst te richten op het afronden van de cursus
- Als je ooit besluit om dingen op AWS te proberen, zorg er dan voor dat je je instances altijd meteen stopt zodra je weggaat, anders krijg je een flinke rekening
Voor nu begin je te leren hoe je met Firehose-streams werkt. Je voorganger heeft een paar Firehose-streams aangemaakt en jij wilt ze allemaal verwijderen om het account schoon te beginnen.
Laten we met een schone lei beginnen in het AWS-account van de stad!
Deze oefening maakt deel uit van de cursus
Streaming data met AWS Kinesis en Lambda
Oefeninstructies
- Importeer boto3 en maak een boto3 Firehose-client.
- Haal de lijst met Firehose Delivery streams op.
- Itereer over de response-inhoud en verwijder elke stream.
- Controleer dat alle delivery streams zijn verwijderd door de resultaten van
.list_delivery_streams()te printen.
Interactieve oefening met praktijkervaring
Probeer deze oefening door deze voorbeeldcode aan te vullen.
# 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.____())