Menggunakan AWS CloudFormation untuk Mengatur Replikasi Neptunus-ke-Neptunus dengan Aplikasi Konsumen Streams

Anda dapat menggunakan AWS CloudFormation template untuk menyiapkan aplikasi konsumen streaming Neptunus untuk mendukung replikasi Neptunus-ke-Neptunus.

Pilih AWS CloudFormation template untuk Wilayah Anda

Untuk meluncurkan AWS CloudFormation tumpukan yang sesuai di AWS CloudFormation konsol, pilih salah satu tombol Launch Stack di tabel berikut, tergantung pada AWS Wilayah yang ingin Anda gunakan.

Wilayah	Lihat	Lihat di Designer	Luncurkan
US East (N. Virginia)	Lihat	Lihat di Desainer
AS Timur (Ohio)	Lihat	Lihat di Desainer
US West (N. California)	Lihat	Lihat di Desainer
US West (Oregon)	Lihat	Lihat di Desainer
Kanada (Pusat)	Lihat	Lihat di Desainer
Amerika Selatan (Sao Paulo)	Lihat	Lihat di Desainer
Europe (Stockholm)	Lihat	Lihat di Desainer
Eropa (Irlandia)	Lihat	Lihat di Desainer
Eropa (London)	Lihat	Lihat di Desainer
Europe (Paris)	Lihat	Lihat di Desainer
Eropa (Frankfurt)	Lihat	Lihat di Desainer
Timur Tengah (Bahrain)	Lihat	Lihat di Desainer
Timur Tengah (UEA)	Lihat	Lihat di Desainer
Israel (Tel Aviv)	Lihat	Lihat di Desainer
Afrika (Cape Town)	Lihat	Lihat di Desainer
Asia Pacific (Tokyo)	Lihat	Lihat di Desainer
Asia Pasifik (Hong Kong)	Lihat	Lihat di Desainer
Asia Pasifik (Seoul)	Lihat	Lihat di Desainer
Asia Pacific (Singapore)	Lihat	Lihat di Desainer
Asia Pacific (Sydney)	Lihat	Lihat di Desainer
Asia Pasifik (Mumbai)	Lihat	Lihat di Desainer
Tiongkok (Beijing)	Lihat	Lihat di Desainer
Tiongkok (Ningxia)	Lihat	Lihat di Desainer
AWS GovCloud (AS-Barat)	Lihat	Lihat di Desainer
AWS GovCloud (AS-Timur)	Lihat	Lihat di Desainer

Pada halaman Buat Tumpukan, pilih Selanjutnya.

Tambahkan detail Tentang tumpukan konsumen streaming Neptunus yang Anda buat

Halaman Tentukan Detail Tumpukan menyediakan properti dan parameter yang dapat Anda gunakan untuk mengontrol pengaturan aplikasi:

Nama Stack — Nama AWS CloudFormation tumpukan baru yang Anda buat. Anda dapat menggunakan nilai default secara umum, NeptuneStreamPoller.

Di bawah Parameter, berikan yang berikut ini:

Konfigurasi jaringan untuk VPC Dimana konsumen streaming berjalan

• VPC— Berikan nama VPC tempat fungsi Lambda polling akan berjalan.

• SubnetIDs— Subnet tempat antarmuka jaringan didirikan. Tambahkan subnet yang sesuai dengan klaster Neptune Anda.

• SecurityGroupIds— Berikan ID grup keamanan yang memberikan akses masuk tulis ke cluster DB Neptunus sumber Anda.

• RouteTableIds— Ini diperlukan untuk membuat titik akhir Amazon DynamoDB di VPC Neptunus Anda, jika Anda belum memilikinya. Anda harus memberikan daftar yang dipisahkan koma dari ID tabel rute yang terkait dengan subnet.

• CreateDDBVPCEndPoint— Nilai Boolean yang defaultnyatrue, menunjukkan apakah perlu membuat titik akhir VPC Dynamo DB atau tidak. Anda hanya perlu mengubahnya menjadi false jika Anda telah membuat titik akhir DynamoDB di VPC Anda.

• CreateMonitoringEndPoint— Nilai Boolean yang defaultnyatrue, menunjukkan apakah perlu membuat titik akhir VPC pemantauan atau tidak.. Anda hanya perlu mengubahnya menjadi false jika Anda telah membuat titik akhir pemantauan di VPC Anda.

Poller Stream

• ApplicationName— Anda biasanya dapat meninggalkan set ini ke default (NeptuneStream). Jika Anda menggunakan nama yang berbeda, itu harus unik.

• LambdaMemorySize— Digunakan untuk mengatur ukuran memori yang tersedia untuk fungsi poller Lambda. Nilai default-nya adalah 2,048 megabyte.

• LambdaRuntime— Bahasa yang digunakan dalam fungsi Lambda yang mengambil item dari aliran Neptunus. Anda dapat mengatur ini baik ke python3.9 atau ke java8.

• LambdaS3Bucket- Bucket Amazon S3 yang berisi artefak kode Lambda. Biarkan ini kosong kecuali Anda menggunakan fungsi polling Lambda khusus yang dimuat dari bucket Amazon S3 yang berbeda.

• LambdaS3Key— Kunci Amazon S3 yang sesuai dengan artefak kode Lambda Anda. Biarkan ini kosong kecuali Anda menggunakan fungsi polling Lambda khusus.

• LambdaLoggingLevel— Secara umum, biarkan set ini ke nilai default, yaituINFO.

• ManagedPolicies— Daftar kebijakan terkelola yang akan digunakan untuk eksekusi fungsi Lambda Anda. Secara umum, biarkan ini kosong kecuali Anda menggunakan fungsi polling Lambda khusus.

• StreamRecordsHandler— Secara umum, biarkan kosong ini kecuali Anda menggunakan penangan khusus untuk catatan di aliran Neptunus.

• StreamRecordsBatchSize— Jumlah maksimum catatan yang akan diambil dari aliran. Anda dapat menggunakan parameter ini untuk menyetel performa. Default (5000) adalah tempat yang baik untuk memulai. Maksimum yang diijinkan adalah 10.000. Semakin tinggi jumlahnya, semakin sedikit panggilan jaringan yang diperlukan untuk membaca catatan dari stream, tetapi semakin banyak memori diperlukan untuk memproses catatan. Nilai yang lebih rendah dari parameter ini menghasilkan throughput yang lebih rendah.

• MaxPollingWaitTime— Waktu tunggu maksimum antara dua jajak pendapat (dalam detik). Menentukan seberapa sering poller Lambda dipanggil untuk polling aliran Neptunus. Tetapkan nilai ini ke 0 untuk polling berkelanjutan. Nilai maksimum adalah 3.600 detik (1 jam). Nilai default (60 detik) adalah tempat yang baik untuk memulai, tergantung seberapa cepat data grafik Anda berubah.

• MaxPollingInterval— Periode polling berkelanjutan maksimum (dalam hitungan detik). Gunakan ini untuk mengatur batas waktu untuk fungsi polling Lambda. Nilainya harus berada dalam kisaran antara 5 detik dan 900 detik. Nilai default (600 detik) adalah tempat yang baik untuk memulai.

• StepFunctionFallbackPeriod— Jumlah unit step-function-fallback-period untuk menunggu poller, setelah itu fungsi langkah dipanggil melalui Amazon CloudWatch Events untuk pulih dari kegagalan. Default (5 menit) adalah tempat yang baik untuk memulai.

• StepFunctionFallbackPeriodUnit— Satuan waktu yang digunakan untuk mengukur sebelumnya StepFunctionFallbackPeriodUnit (minutes,hours, ataudays). Default (minutes) umumnya cukup.

Aliran Neptunus

• NeptuneStreamEndpoint— (Wajib) Titik akhir aliran sumber Neptunus. Ini mengambil salah satu dari dua bentuk:

  • https://your DB cluster:port/propertygraph/stream(atau aliasnya,https://your DB cluster:port/pg/stream).

  • https://your DB cluster:port/sparql/stream.

• Neptune Query Engine— Pilih Gremlin, OpenCypher, atau SPARQL.

• IAMAuthEnabledOnSourceStream— Jika cluster DB Neptunus Anda menggunakan otentikasi IAM, atur parameter ini ke. true

• StreamDBClusterResourceId— Jika cluster DB Neptunus Anda menggunakan otentikasi IAM, atur parameter ini ke ID sumber daya cluster. ID sumber daya tidak sama dengan ID cluster. Sebaliknya, ia mengambil bentuk: cluster- diikuti oleh 28 karakter alfa-numerik. Ini dapat ditemukan di bawah Detail Klaster di konsol Neptune.

Target kluster DB Neptunus

• TargetNeptuneClusterEndpoint— Titik akhir cluster (hanya nama host) dari cluster cadangan target.

  Perhatikan bahwa jika Anda menentukanTargetNeptuneClusterEndpoint, Anda juga tidak dapat menentukanTargetSPARQLUpdateEndpoint.

• TargetNeptuneClusterPort— Nomor port untuk cluster target.

  Perhatikan bahwa jika Anda menentukanTargetSPARQLUpdateEndpoint, pengaturan TargetNeptuneClusterPort untuk diabaikan.

• IAMAuthEnabledOnTargetCluster— Setel ke true jika otentikasi IAM akan diaktifkan pada cluster target.

• TargetAWSRegion— AWS Wilayah cluster cadangan target, sepertius-east-1). Anda harus memberikan parameter ini hanya ketika AWS wilayah cluster cadangan target berbeda dari wilayah cluster sumber Neptunus, seperti dalam kasus replikasi lintas wilayah. Jika wilayah sumber dan target sama, parameter ini opsional.

  Perhatikan bahwa jika TargetAWSRegion nilainya bukan AWS wilayah valid yang didukung Neptunus, prosesnya gagal.

• TargetNeptuneDBClusterResourceId— Opsional: ini hanya diperlukan ketika otentikasi IAM diaktifkan pada cluster DB target. Setel ke ID sumber daya dari cluster target.

• SPARQLTripleOnlyMode— Bendera Boolean yang menentukan apakah mode triple-only diaktifkan. Dalam mode triple-only, tidak ada replikasi grafik bernama. Nilai default-nya adalah false.

• TargetSPARQLUpdateEndpoint— URL titik akhir target untuk pembaruan SPARQL, seperti. https://abc.com/xyz Endpoint ini dapat berupa toko SPARQL yang mendukung quad atau triple.

  Perhatikan bahwa jika Anda menentukanTargetSPARQLUpdateEndpoint, Anda juga tidak dapat menentukanTargetNeptuneClusterEndpoint, dan pengaturan diabaikan. TargetNeptuneClusterPort

• BlockSparqlReplicationOnBlankNode — Bendera Boolean yang, jika disetel ketrue, menghentikan replikasi untuk BlankNode data SPARQL (RDF). Nilai bawaannya adalah false.

Alarm

• Required to create Cloud watch Alarm— Atur ini ke true jika Anda ingin membuat CloudWatch alarm untuk tumpukan baru.

• SNS Topic ARN for Cloudwatch Alarm Notifications— Topik SNS ARN CloudWatch tempat pemberitahuan alarm harus dikirim (hanya diperlukan jika alarm diaktifkan).

• Email for Alarm Notifications— Alamat email tempat pemberitahuan alarm harus dikirim (hanya diperlukan jika alarm diaktifkan).

Untuk tujuan notifikasi alarm, Anda dapat menambahkan SNS saja, hanya email, atau SNS dan email.

Jalankan AWS CloudFormation Template

Sekarang Anda dapat menyelesaikan proses instans aplikasi konsumen stream Neptune provisioning sebagai berikut:

1. Di AWS CloudFormation, pada halaman Tentukan Detail Tumpukan, pilih Berikutnya.

2. Pada halaman Opsi, pilih Selanjutnya.

3. Pada halaman Review, pilih kotak centang pertama untuk mengetahui bahwa AWS CloudFormation akan membuat sumber daya IAM. Pilih kotak centang kedua untuk mengetahui CAPABILITY_AUTO_EXPAND untuk tumpukan baru.

   catatan

   CAPABILITY_AUTO_EXPAND secara eksplisit mengakui bahwa macro akan diperluas saat membuat tumpukan, tanpa review sebelumnya. Pengguna sering kali membuat perubahan yang ditetapkan dari templat yang diproses, sehingga perubahan yang dibuat oleh makro bisa direview tepat sebelum membuat tumpukan. Untuk informasi selengkapnya, lihat AWS CloudFormation CreateStackAPI di Referensi AWS CloudFormation API.

   Lalu pilih Buat.

Untuk memperbarui poller aliran dengan artefak Lambda terbaru

Anda dapat memperbarui poller aliran dengan artefak kode Lambda terbaru sebagai berikut:

1. Di AWS Management Console, navigasikan ke AWS CloudFormation dan pilih AWS CloudFormation tumpukan induk utama.

2. Pilih opsi Perbarui untuk tumpukan.

3. Pilih Ganti template saat ini.

4. Untuk sumber template, pilih URL Amazon S3 dan masukkan URL S3 berikut:

   https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_neptune.json

5. Pilih Berikutnya tanpa mengubah AWS CloudFormation parameter apa pun.

6. Pilih Update Stack.

Tumpukan sekarang akan memperbarui artefak Lambda dengan yang terbaru.