Gestionar flujos de entrega Firehose
La ingeniería de datos a veces implica gestionar permisos, usuarios, y utilizar para ello herramientas de GUI en lugar de scripts. En este curso, te mostraremos cómo utilizar boto3 para utilizar Kinesis y Lambda, pero también cómo ejecutar ciertas operaciones en AWS.
A lo largo del curso, las operaciones en AWS se realizan por ti, para que puedas centrarte en el aspecto de la programación.
Los screencasts están aquí para darte un contexto completo sobre cómo funcionan las cosas. Siéntete libre de probar estas operaciones en AWS por tu cuenta, pero es totalmente opcional:
- No te examinarás en la plataforma AWS
- Las operaciones de AWS se realizan por ti a lo largo del curso, por lo que te recomendamos encarecidamente que te centres primero en terminar el curso.
- Si alguna vez decides probar cosas en AWS, asegúrate de detener siempre tus instancias en cuanto salgas o acabarás con una factura considerable.
Por ahora, estás empezando a aprender a interactuar con los flujos Firehose. Tu predecesor ha creado unos cuantos flujos Firehose, y quieres eliminarlos todos para que la cuenta empiece de cero.
¡Empecemos de nuevo en la cuenta AWS de la ciudad!
Este ejercicio forma parte del curso
Streaming de datos con AWS Kinesis y Lambda
Instrucciones de ejercicio
- Importa boto3 y crea el cliente boto3 Firehose.
- Obtén la lista de flujos Firehose Delivery.
- Iterar sobre el contenido de la respuesta y borrar cada flujo.
- Comprueba que se han borrado todos los flujos de entrega imprimiendo los resultados de
.list_delivery_streams().
Ejercicio interactivo práctico
Pruebe este ejercicio completando este código de muestra.
# 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.____())