Mengelola Firehose delivery stream
Rekayasa data terkadang melibatkan pengelolaan izin, pengguna, dan penggunaan alat GUI untuk melakukannya alih-alih skrip. Dalam kursus ini, kami akan menunjukkan cara menggunakan boto3 untuk bekerja dengan Kinesis dan Lambda, serta cara menjalankan operasi tertentu di AWS.
Sepanjang kursus, operasi di AWS telah diurus untuk Anda, sehingga Anda dapat berfokus pada aspek pemrogramannya.
Screencast disediakan untuk memberi Anda konteks lengkap tentang cara kerjanya. Silakan coba operasi ini sendiri di AWS, tetapi ini sepenuhnya opsional:
- Anda tidak akan diuji di platform AWS
- Operasi AWS telah diurus untuk Anda sepanjang kursus, jadi kami sangat menyarankan agar Anda fokus menyelesaikan kursus terlebih dahulu
- Jika suatu saat Anda memutuskan untuk mencoba langsung di AWS, pastikan selalu menghentikan instance segera setelah selesai, jika tidak tagihan Anda bisa membengkak
Untuk saat ini, Anda mulai mempelajari cara berinteraksi dengan stream Firehose. Pendahulu Anda telah membuat beberapa stream Firehose, dan Anda ingin menghapus semuanya agar akun mulai dari awal.
Mari kita mulai bersih di akun AWS milik kota!
Latihan ini adalah bagian dari kursus
Streaming Data dengan AWS Kinesis dan Lambda
Petunjuk latihan
- Impor boto3 dan buat klien boto3 untuk Firehose.
- Dapatkan daftar Firehose Delivery stream.
- Iterasi konten respons dan hapus setiap stream.
- Verifikasi bahwa semua delivery stream telah dihapus dengan mencetak hasil dari
.list_delivery_streams().
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# 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.____())