updated Readme using Writeme

Author: scmacdon

.doc_gen/metadata/neptune_metadata.yaml

@@ -1,7 +1,7 @@
 # zexi 0.4.0
 neptune_Hello:
   title: Hello &neptune;
-  title_abbrev: Hello &neptune;
+  title_abbrev: Hello &BR;
   synopsis: get started using &neptune;.
   category: Hello
   languages:
@@ -146,19 +146,6 @@ neptune_CreateDBSubnetGroup:
                 - neptune.java2.create.subnet.main
   services:
     neptune: {CreateDBSubnetGroup}
-neptune_CreateDBSubnetGroup:
-  languages:
-    Java:
-      versions:
-        - sdk_version: 2
-          github: javav2/example_code/neptune
-          sdkguide:
-          excerpts:
-            - description:
-              snippet_tags:
-                - neptune.java2.create.subnet.main
-  services:
-    neptune: {CreateDBSubnetGroup}
 neptune_Scenario:
   synopsis_list:
     - Create an &neptunelong; Subnet Group.

javav2/example_code/neptune/src/main/java/com/example/neptune/scenerio/NeptuneActions.java

@@ -206,7 +206,7 @@ private void checkInstanceDeletedRecursive(String instanceId, long startTime, Co
 
                     String status = response.dbInstances().get(0).dbInstanceStatus();
                     long elapsed = (System.currentTimeMillis() - startTime) / 1000;
-                    logger.info("\r  Waiting: Instance %s status: %-10s (%ds elapsed)", instanceId, status, elapsed);
+                    System.out.printf("\r  Waiting: Instance %s status: %-10s (%ds elapsed)", instanceId, status, elapsed);
                     System.out.flush();
 
                     CompletableFuture.delayedExecutor(20, TimeUnit.SECONDS)
@@ -265,13 +265,25 @@ private void checkClusterStatusRecursive(String clusterId, String desiredStatus,
      *
      * @param clusterIdentifier the unique identifier of the DB cluster to be stopped
      */
-    public void startDBCluster(String clusterIdentifier) {
+    public CompletableFuture<StartDbClusterResponse> startDBClusterAsync(String clusterIdentifier) {
         StartDbClusterRequest clusterRequest = StartDbClusterRequest.builder()
                 .dbClusterIdentifier(clusterIdentifier)
                 .build();
 
-        getAsyncClient().startDBCluster(clusterRequest);
-        logger.info(" DB Cluster starting...");
+        return getAsyncClient().startDBCluster(clusterRequest)
+                .whenComplete((response, error) -> {
+                    if (error != null) {
+                        Throwable cause = error.getCause() != null ? error.getCause() : error;
+
+                        if (cause instanceof ResourceNotFoundException) {
+                            throw (ResourceNotFoundException) cause;
+                        }
+
+                        throw new RuntimeException("Failed to start DB cluster: " + cause.getMessage(), cause);
+                    } else {
+                        logger.info("DB Cluster starting: " + clusterIdentifier);
+                    }
+                });
     }
     // snippet-end:[neptune.java2.start.cluster.main]
 
@@ -281,14 +293,27 @@ public void startDBCluster(String clusterIdentifier) {
      *
      * @param clusterIdentifier the unique identifier of the DB cluster to be stopped
      */
-    public void stopDBCluster(String clusterIdentifier) {
+    public CompletableFuture<StopDbClusterResponse> stopDBClusterAsync(String clusterIdentifier) {
         StopDbClusterRequest clusterRequest = StopDbClusterRequest.builder()
                 .dbClusterIdentifier(clusterIdentifier)
                 .build();
 
-        getAsyncClient().stopDBCluster(clusterRequest);
-        logger.info("DB Cluster Stopped");
+        return getAsyncClient().stopDBCluster(clusterRequest)
+                .whenComplete((response, error) -> {
+                    if (error != null) {
+                        Throwable cause = error.getCause() != null ? error.getCause() : error;
+
+                        if (cause instanceof ResourceNotFoundException) {
+                            throw (ResourceNotFoundException) cause;
+                        }
+
+                        throw new RuntimeException("Failed to stop DB cluster: " + cause.getMessage(), cause);
+                    } else {
+                        logger.info("DB Cluster stopped: " + clusterIdentifier);
+                    }
+                });
     }
+
     // snippet-end:[neptune.java2.stop.cluster.main]
 
     // snippet-start:[neptune.java2.describe.cluster.main]
@@ -329,6 +354,11 @@ public CompletableFuture<Void> describeDBClustersAsync(String clusterId) {
                 })
                 .exceptionally(ex -> {
                     Throwable cause = ex.getCause() != null ? ex.getCause() : ex;
+
+                    if (cause instanceof ResourceNotFoundException) {
+                        throw (ResourceNotFoundException) cause;
+                    }
+
                     throw new RuntimeException("Failed to describe the DB cluster: " + cause.getMessage(), cause);
                 });
     }
@@ -439,7 +469,6 @@ public CompletableFuture<String> createDBInstanceAsync(String dbInstanceId, Stri
     }
     // snippet-end:[neptune.java2.create.dbinstance.main]
 
-
     // snippet-start:[neptune.java2.create.cluster.main]
 
     /**

javav2/example_code/neptune/src/main/java/com/example/neptune/scenerio/NeptuneScenario.java

@@ -5,8 +5,11 @@
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import software.amazon.awssdk.services.neptunegraph.model.ResourceNotFoundException;
+import software.amazon.awssdk.services.neptunegraph.model.ServiceQuotaExceededException;
 
 import java.util.Scanner;
+import java.util.concurrent.CompletionException;
 
 // snippet-start:[neptune.java2.scenario.main]
 public class NeptuneScenario {
@@ -26,33 +29,32 @@ public static void main(String[] args) {
                     clusterName     - The unique identifier for the Neptune DB cluster.
                     dbInstanceId    - The identifier for a specific Neptune DB instance within the cluster.
                 """;
-        String subnetGroupName = "neptuneSubnetGroup56";
-        String clusterName = "neptuneCluster56";
-        String dbInstanceId = "neptuneDB56";
+        String subnetGroupName = "neptuneSubnetGroup58";
+        String clusterName = "neptuneCluster58";
+        String dbInstanceId = "neptuneDB58";
 
         logger.info("""
-                     Amazon Neptune is a fully managed graph 
-                     database service by AWS, designed specifically
-                     for handling complex relationships and connected 
-                     datasets at scale. It supports two popular graph models: 
-                     property graphs (via openCypher and Gremlin) and RDF 
-                     graphs (via SPARQL). This makes Neptune ideal for 
-                     use cases such as knowledge graphs, fraud detection, 
-                     social networking, recommendation engines, and 
-                     network management, where relationships between 
-                     entities are central to the data.
+                   Amazon Neptune is a fully managed graph 
+                   database service by AWS, designed specifically
+                   for handling complex relationships and connected 
+                   datasets at scale. It supports two popular graph models: 
+                   property graphs (via openCypher and Gremlin) and RDF 
+                   graphs (via SPARQL). This makes Neptune ideal for 
+                   use cases such as knowledge graphs, fraud detection, 
+                   social networking, recommendation engines, and 
+                   network management, where relationships between 
+                   entities are central to the data.
                     
-                    Being fully managed, Neptune handles database 
-                    provisioning, patching, backups, and replication, 
-                    while also offering high availability and durability 
-                    within AWS's infrastructure.
+                   Being fully managed, Neptune handles database 
+                   provisioning, patching, backups, and replication, 
+                   while also offering high availability and durability 
+                   within AWS's infrastructure.
                     
-                    For developers, programming with Neptune allows 
-                    for building intelligent, relationship-aware 
-                    applications that go beyond traditional tabular 
-                    databases. Developers can use the AWS SDK for Java 
-                    V2 to automate infrastructure operations 
-                    (via NeptuneClient). 
+                   For developers, programming with Neptune allows 
+                   for building intelligent, relationship-aware 
+                   applications that go beyond traditional tabular 
+                   databases. Developers can use the AWS SDK for Java 
+                   to automate infrastructure operations (via NeptuneClient). 
                     
                     Let's get started...
                     """);
@@ -65,23 +67,56 @@ public static void runScenario(String subnetGroupName, String dbInstanceId, Stri
         logger.info("1. Create a Neptune DB Subnet Group");
         logger.info("The Neptune DB subnet group is used when launching a Neptune cluster");
         waitForInputToContinue(scanner);
-        neptuneActions.createSubnetGroupAsync(subnetGroupName).join();
+        try {
+            neptuneActions.createSubnetGroupAsync(subnetGroupName).join();
+
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ServiceQuotaExceededException) {
+                logger.error("The request failed due to service quota exceeded: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
         logger.info(DASHES);
         logger.info("2. Create a Neptune Cluster");
         logger.info("A Neptune Cluster allows you to store and query highly connected datasets with low latency.");
         waitForInputToContinue(scanner);
-        String dbClusterId = neptuneActions.createDBClusterAsync(clusterName).join();
+        String dbClusterId;
+        try {
+            dbClusterId = neptuneActions.createDBClusterAsync(clusterName).join();
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ServiceQuotaExceededException) {
+                logger.error("The request failed due to service quota exceeded: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
+
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
         logger.info(DASHES);
         logger.info("3. Create a Neptune DB Instance");
         logger.info("In this step, we add a new database instance to the Neptune cluster");
         waitForInputToContinue(scanner);
+        try {
         neptuneActions.createDBInstanceAsync(dbInstanceId, dbClusterId).join();
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ServiceQuotaExceededException) {
+                logger.error("The request failed due to service quota exceeded: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
@@ -92,14 +127,30 @@ public static void runScenario(String subnetGroupName, String dbInstanceId, Stri
                     becomes available. This may take around 10 minutes.
                     """);
         waitForInputToContinue(scanner);
-        neptuneActions.checkInstanceStatus(dbInstanceId, "available").join();
+        try {
+            neptuneActions.checkInstanceStatus(dbInstanceId, "available").join();
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            logger.error("An unexpected error occurred.", cause);
+            return;
+        }
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
         logger.info(DASHES);
         logger.info("5.Show Neptune Cluster details");
         waitForInputToContinue(scanner);
-        neptuneActions.describeDBClustersAsync(clusterName).join();
+        try {
+            neptuneActions.describeDBClustersAsync(clusterName).join();
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ResourceNotFoundException) {
+                logger.error("The request failed due to the resource not found: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
@@ -110,8 +161,18 @@ public static void runScenario(String subnetGroupName, String dbInstanceId, Stri
                     until the cluster is in a stopped state.
                     """);
         waitForInputToContinue(scanner);
-        neptuneActions.stopDBCluster(dbClusterId);
-        neptuneActions.waitForClusterStatus(dbClusterId, "stopped");
+        try {
+            neptuneActions.stopDBClusterAsync(dbClusterId);
+            neptuneActions.waitForClusterStatus(dbClusterId, "stopped");
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ResourceNotFoundException) {
+                logger.error("The request failed due to the resource not found: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
         waitForInputToContinue(scanner);
         logger.info(DASHES);
 
@@ -123,18 +184,38 @@ public static void runScenario(String subnetGroupName, String dbInstanceId, Stri
                     We will also poll the instance status.
                     """);
         waitForInputToContinue(scanner);
-        neptuneActions.startDBCluster(dbClusterId);
-        neptuneActions.waitForClusterStatus(dbClusterId, "available");
-        neptuneActions.checkInstanceStatus(dbInstanceId, "available").join();
+        try {
+            neptuneActions.startDBClusterAsync(dbClusterId);
+            neptuneActions.waitForClusterStatus(dbClusterId, "available");
+            neptuneActions.checkInstanceStatus(dbInstanceId, "available").join();
+        } catch (CompletionException ce) {
+            Throwable cause = ce.getCause();
+            if (cause instanceof ResourceNotFoundException) {
+                logger.error("The request failed due to the resource not found: {}", cause.getMessage());
+            } else {
+                logger.error("An unexpected error occurred.", cause);
+            }
+            return;
+        }
         logger.info(DASHES);
+
         logger.info(DASHES);
         logger.info("8. Delete the Neptune Assets");
         logger.info("Would you like to delete the Neptune Assets? (y/n)");
         String delAns = scanner.nextLine().trim();
         if (delAns.equalsIgnoreCase("y")) {
             logger.info("You selected to delete the Neptune assets.");
-            neptuneActions.deleteNeptuneResourcesAsync(dbInstanceId, clusterName, subnetGroupName);
-
+            try {
+                neptuneActions.deleteNeptuneResourcesAsync(dbInstanceId, clusterName, subnetGroupName);
+            } catch (CompletionException ce) {
+                Throwable cause = ce.getCause();
+                if (cause instanceof ResourceNotFoundException) {
+                    logger.error("The request failed due to the resource not found: {}", cause.getMessage());
+                } else {
+                    logger.error("An unexpected error occurred.", cause);
+                }
+                return;
+            }
         } else {
             logger.info("You selected not to delete Neptune assets.");
         }

javav2/example_code/neptune/src/test/java/NeptuneTest.java

@@ -76,7 +76,7 @@ public void testDescribeDBCluster() {
     @Order(6)
     public void testStopDBCluster() {
         assertDoesNotThrow(() -> {
-            neptuneActions.stopDBCluster(dbClusterId);
+            neptuneActions.stopDBClusterAsync(dbClusterId);
             neptuneActions.waitForClusterStatus(dbClusterId,"stopped");
         });
         System.out.println("Test 6 passed");
@@ -87,7 +87,7 @@ public void testStopDBCluster() {
     @Order(7)
     public void testStartDBCluster() {
         assertDoesNotThrow(() -> {
-            neptuneActions.startDBCluster(dbClusterId);
+            neptuneActions.startDBClusterAsync(dbClusterId);
             neptuneActions.waitForClusterStatus(dbClusterId,"available");
             neptuneActions.checkInstanceStatus(dbInstanceId, "available").join();
         });