D'autres exemples de AWS SDK sont disponibles dans le référentiel [AWS Doc SDK Examples](https://github.com/awsdocs/aws-doc-sdk-examples) GitHub .
Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
# Exemples de base pour AWS IoT FleetWise l'utilisation AWS SDKs
Les exemples de code suivants montrent comment utiliser les principes de base de AWS IoT FleetWise with AWS SDKs.
**Contents**
+ [Bonjour AWS IoT FleetWise](iotfleetwise_example_iotfleetwise_Hello_section.md)
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
+ [Actions](iotfleetwise_code_examples_actions.md)
+ [`createDecoderManifest`](iotfleetwise_example_iotfleetwise_CreateDecoderManifest_section.md)
+ [`createFleet`](iotfleetwise_example_iotfleetwise_CreateFleet_section.md)
+ [`createModelManifest`](iotfleetwise_example_iotfleetwise_CreateModelManifest_section.md)
+ [`createSignalCatalog`](iotfleetwise_example_iotfleetwise_CreateSignalCatalog_section.md)
+ [`createVehicle`](iotfleetwise_example_iotfleetwise_CreateVehicle_section.md)
+ [`deleteDecoderManifest`](iotfleetwise_example_iotfleetwise_DeleteDecoderManifest_section.md)
+ [`deleteFleet`](iotfleetwise_example_iotfleetwise_DeleteFleet_section.md)
+ [`deleteModelManifest`](iotfleetwise_example_iotfleetwise_DeleteModelManifest_section.md)
+ [`deleteSignalCatalog`](iotfleetwise_example_iotfleetwise_DeleteSignalCatalog_section.md)
+ [`deleteVehicle`](iotfleetwise_example_iotfleetwise_DeleteVehicle_section.md)
+ [`getDecoderManifest`](iotfleetwise_example_iotfleetwise_GetDecoderManifest_section.md)
+ [`getModelManifest`](iotfleetwise_example_iotfleetwise_GetModelManifest_section.md)
+ [`getVehicle`](iotfleetwise_example_iotfleetwise_GetVehicle_section.md)
+ [`listSignalCatalogNodes`](iotfleetwise_example_iotfleetwise_ListSignalCatalogNodes_section.md)
+ [`updateDecoderManifest`](iotfleetwise_example_iotfleetwise_UpdateDecoderManifest_section.md)
+ [`updateModelManifest`](iotfleetwise_example_iotfleetwise_UpdateModelManifest_section.md)
# Bonjour AWS IoT FleetWise
Les exemples de code suivants montrent comment démarrer avec AWS IoT FleetWise.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
public class HelloFleetwise {
public static void main(String[] args) {
ListSignalCatalogs();
}
public static void ListSignalCatalogs() {
try (IoTFleetWiseClient fleetWiseClient = IoTFleetWiseClient.builder()
.region(Region.US_EAST_1)
.credentialsProvider(DefaultCredentialsProvider.create())
.build()) {
ListSignalCatalogsRequest request = ListSignalCatalogsRequest.builder()
.maxResults(10) // Optional: limit per page
.build();
ListSignalCatalogsIterable paginator = fleetWiseClient.listSignalCatalogsPaginator(request);
boolean found = false;
for (ListSignalCatalogsResponse response : paginator) {
for (SignalCatalogSummary summary : response.summaries()) {
found = true;
System.out.println("Catalog Name: " + summary.name());
System.out.println("ARN: " + summary.arn());
System.out.println("Created: " + summary.creationTime());
System.out.println("Last Modified: " + summary.lastModificationTime());
System.out.println("---------------");
}
}
if (!found) {
System.out.println("No AWS Fleetwise Signal Catalogs were found.");
}
} catch (IoTFleetWiseException e) {
System.err.println("Error listing signal catalogs: " + e.awsErrorDetails().errorMessage());
throw new RuntimeException(e);
}
}
}
```
+ Pour plus de détails sur l'API, voir [listSignalCatalogsPaginator dans la référence](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogsPaginator) des *AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
Before running this Kotlin code example, set up your development environment,
including your credentials.
For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
suspend fun main() {
listSignalCatalogs()
}
/**
* Lists the AWS FleetWise Signal Catalogs associated with the current AWS account.
*/
suspend fun listSignalCatalogs() {
val request = ListSignalCatalogsRequest {
maxResults = 10
}
IotFleetWiseClient { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.listSignalCatalogs(request)
val summaries = response.summaries
if (summaries.isNullOrEmpty()) {
println("No AWS FleetWise Signal Catalogs were found.")
} else {
summaries.forEach { summary ->
with(summary) {
println("Catalog Name: $name")
println("ARN: $arn")
println("Created: $creationTime")
println("Last Modified: $lastModificationTime")
println("---------------")
}
}
}
}
}
```
+ Pour plus de détails sur l'API, voir [listSignalCatalogsPaginator](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans le *AWS SDK pour la référence de l'API Kotlin*.
------
# Apprenez les bases AWS IoT FleetWise d'un AWS SDK
Les exemples de code suivants montrent comment :
+ créer un ensemble de signaux standardisés ;
+ créer une flotte qui représente un groupe de véhicules ;
+ créer un manifeste du modèle ;
+ créer un manifeste du décodeur ;
+ vérifier le statut du manifeste du modèle ;
+ vérifier le statut du décodeur ;
+ créer d’un objet IoT ;
+ créer un véhicule ;
+ afficher les détails du véhicule ;
+ Supprimez les AWS IoT FleetWise actifs.
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
Exécutez un scénario interactif illustrant AWS IoT SiteWise les fonctionnalités.
```
public class FleetwiseScenario {
public static final String DASHES = new String(new char[80]).replace("\0", "-");
static FleetwiseActions actions = new FleetwiseActions();
private static final Logger logger = LoggerFactory.getLogger(FleetwiseScenario.class);
static Scanner scanner = new Scanner(System.in);
public static void main(String[] args) {
final String usage =
"""
Usage:
Where:
signalCatalogName - The name of the Signal Catalog to create (eg, catalog30).
manifestName - The name of the Vehicle Model (Model Manifest) to create (eg, manifest30).
fleetId - The ID of the Fleet to create (eg, fleet30).
vecName - The name of the Vehicle to create (eg, vehicle30).
decName - The name of the Decoder Manifest to create (eg, decManifest30).
""";
if (args.length != 5) {
logger.info(usage);
return;
}
String signalCatalogName = args[0];
String manifestName = args[1];
String fleetId = args[2];
String vecName = args[3];
String decName = args[4];
logger.info(
"""
AWS IoT FleetWise is a managed service that simplifies the
process of collecting, organizing, and transmitting vehicle
data to the cloud in near real-time. Designed for automakers
and fleet operators, it allows you to define vehicle models,
specify the exact data you want to collect (such as engine
temperature, speed, or battery status), and send this data to
AWS for analysis. By using intelligent data collection
techniques, IoT FleetWise reduces the volume of data
transmitted by filtering and transforming it at the edge,
helping to minimize bandwidth usage and costs.
At its core, AWS IoT FleetWise helps organizations build
scalable systems for vehicle data management and analytics,
supporting a wide variety of vehicles and sensor configurations.
You can define signal catalogs and decoder manifests that describe
how raw CAN bus signals are translated into readable data, making
the platform highly flexible and extensible. This allows
manufacturers to optimize vehicle performance, improve safety,
and reduce maintenance costs by gaining real-time visibility
into fleet operations.
""");
waitForInputToContinue(scanner);
logger.info(DASHES);
try {
runScenario(signalCatalogName, manifestName, fleetId, vecName, decName);
} catch (RuntimeException e) {
logger.info(e.getMessage());
}
}
private static void runScenario(String signalCatalogName,
String manifestName,
String fleetId,
String vecName,
String decName) {
logger.info(DASHES);
logger.info("1. Creates a collection of standardized signals that can be reused to create vehicle models");
String signalCatalogArn;
try {
signalCatalogArn = actions.createSignalCatalogAsync(signalCatalogName).join();
logger.info("The collection ARN is " + signalCatalogArn);
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ValidationException) {
logger.error("The request failed due to a validation issue: {}", cause.getMessage());
} else {
logger.error("An unexpected error occurred.", cause);
}
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("2. Create a fleet that represents a group of vehicles");
logger.info(
"""
Creating an IoT FleetWise fleet allows you to efficiently collect,
organize, and transfer vehicle data to the cloud, enabling real-time
insights into vehicle performance and health.
It helps reduce data costs by allowing you to filter and prioritize
only the most relevant vehicle signals, supporting advanced analytics
and predictive maintenance use cases.
""");
waitForInputToContinue(scanner);
String fleetid;
try {
fleetid = actions.createFleetAsync(signalCatalogArn, fleetId).join();
logger.info("The fleet Id is " + fleetid);
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ResourceNotFoundException) {
logger.error("The resource was not found: {}", cause.getMessage());
} else {
logger.error("An unexpected error occurred.", cause);
}
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("3. Create a model manifest");
logger.info(
"""
An AWS IoT FleetWise manifest defines the structure and
relationships of vehicle data. The model manifest specifies
which signals to collect and how they relate to vehicle systems,
while the decoder manifest defines how to decode raw vehicle data
into meaningful signals.
""");
waitForInputToContinue(scanner);
String manifestArn;
try {
List nodes = actions.listSignalCatalogNodeAsync(signalCatalogName).join();
manifestArn = actions.createModelManifestAsync(manifestName, signalCatalogArn, nodes).join();
logger.info("The manifest ARN is {}", manifestArn);
} 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("4. Create a decoder manifest");
logger.info(
"""
A decoder manifest in AWS IoT FleetWise defines how raw vehicle
data (such as CAN signals) should be interpreted and decoded
into meaningful signals. It acts as a translation layer
that maps vehicle-specific protocols to standardized data formats
using decoding rules. This is crucial for extracting usable
data from different vehicle models, even when their data
formats vary.
""");
waitForInputToContinue(scanner);
String decArn;
try {
decArn = actions.createDecoderManifestAsync(decName, manifestArn).join();
logger.info("The decoder manifest ARN is {}", decArn);
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
logger.error("An unexpected error occurred.", cause);
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info("5. Check the status of the model manifest");
logger.info(
"""
The model manifest must be in an ACTIVE state before it can be used
to create or update a vehicle.
""");
waitForInputToContinue(scanner);
try {
actions.updateModelManifestAsync(manifestName);
actions.waitForModelManifestActiveAsync(manifestName).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
logger.error("An unexpected error occurred while waiting for the model manifest status.", cause);
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info("6. Check the status of the decoder");
logger.info(
"""
The decoder manifest must be in an ACTIVE state before it can be used
to create or update a vehicle.
""");
waitForInputToContinue(scanner);
try {
actions.updateDecoderManifestAsync(decName);
actions.waitForDecoderManifestActiveAsync(decName).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
logger.error("An unexpected error occurred while waiting for the decoder manifest status.", cause);
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("7. Create an IoT Thing");
logger.info(
"""
AWS IoT FleetWise expects an existing AWS IoT Thing with the same
name as the vehicle name you are passing to createVehicle method.
Before calling createVehicle(), you must create an AWS IoT Thing
with the same name using the AWS IoT Core service.
""");
waitForInputToContinue(scanner);
try {
actions.createThingIfNotExistsAsync(vecName).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ResourceAlreadyExistsException) {
logger.error("The resource exists: {}", cause.getMessage());
} else {
logger.error("An unexpected error occurred.", cause);
return;
}
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("8. Create a vehicle");
logger.info(
"""
Creating a vehicle in AWS IoT FleetWise allows you to digitally
represent and manage a physical vehicle within the AWS ecosystem.
This enables efficient ingestion, transformation, and transmission
of vehicle telemetry data to the cloud for analysis.
""");
waitForInputToContinue(scanner);
try {
actions.createVehicleAsync(vecName, manifestArn, decArn).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ResourceNotFoundException) {
logger.error("The required resource was not found: {}", cause.getMessage());
} else {
logger.error("An unexpected error occurred while creating vehicle.", cause);
}
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("9. Display vehicle details");
waitForInputToContinue(scanner);
try {
actions.getVehicleDetailsAsync(vecName).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ResourceNotFoundException) {
logger.error("The resource was not found: {}", cause.getMessage());
} else {
logger.error("An unexpected error occurred.", cause);
}
return;
}
waitForInputToContinue(scanner);
logger.info(DASHES);
logger.info(DASHES);
logger.info("10. Delete the AWS IoT Fleetwise Assets");
logger.info("Would you like to delete the IoT Fleetwise Assets? (y/n)");
String delAns = scanner.nextLine().trim();
if (delAns.equalsIgnoreCase("y")) {
try {
actions.deleteVehicleAsync(vecName).join();
actions.deleteDecoderManifestAsync(decName).join();
actions.deleteModelManifestAsync(manifestName).join();
actions.deleteFleetAsync(fleetid).join();
actions.deleteSignalCatalogAsync(signalCatalogName).join();
} catch (CompletionException ce) {
Throwable cause = ce.getCause();
if (cause instanceof ResourceNotFoundException) {
// Handle the case where the resource is not found.
logger.error("The resource was not found: {}", cause.getMessage());
} else if (cause instanceof RuntimeException) {
// Handle other runtime exceptions.
logger.error("An unexpected error occurred: {}", cause.getMessage());
} else {
// Catch any other unexpected exceptions.
logger.error("An unknown error occurred.", cause);
}
return;
}
logger.info(DASHES);
logger.info(
"""
Thank you for checking out the AWS IoT Fleetwise Service Use demo. We hope you
learned something new, or got some inspiration for your own apps today.
For more AWS code examples, have a look at:
https://docs.aws.amazon.com/code-library/latest/ug/what-is-code-library.html
""");
logger.info(DASHES);
} else {
logger.info("The AWS resources will not be deleted.");
}
}
private static void waitForInputToContinue(Scanner scanner) {
while (true) {
logger.info("");
logger.info("Enter 'c' followed by to continue:");
String input = scanner.nextLine();
if (input.trim().equalsIgnoreCase("c")) {
logger.info("Continuing with the program...");
logger.info("");
break;
} else {
logger.info("Invalid input. Please try again.");
}
}
}
}
```
Une classe wrapper pour les méthodes du AWS IoT FleetWise SDK.
```
public class FleetwiseActions {
private static final Logger logger = LoggerFactory.getLogger(FleetwiseActions.class);
private static IoTFleetWiseAsyncClient ioTFleetWiseAsyncClient;
private static IoTFleetWiseAsyncClient getAsyncClient() {
if (ioTFleetWiseAsyncClient == null) {
SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder()
.maxConcurrency(100)
.connectionTimeout(Duration.ofSeconds(60))
.readTimeout(Duration.ofSeconds(60))
.writeTimeout(Duration.ofSeconds(60))
.build();
ClientOverrideConfiguration overrideConfig = ClientOverrideConfiguration.builder()
.apiCallTimeout(Duration.ofMinutes(2))
.apiCallAttemptTimeout(Duration.ofSeconds(90))
.retryStrategy(RetryMode.STANDARD)
.build();
ioTFleetWiseAsyncClient = IoTFleetWiseAsyncClient.builder()
.httpClient(httpClient)
.overrideConfiguration(overrideConfig)
.build();
}
return ioTFleetWiseAsyncClient;
}
/**
* Creates a signal catalog.
*
* @param signalCatalogName the name of the signal catalog to be created
* @return a {@link CompletableFuture} that completes with the Amazon Resource Name (ARN) of the created signal catalog
*/
public CompletableFuture createSignalCatalogAsync(String signalCatalogName) {
return deleteSignalCatalogIfExistsAsync(signalCatalogName)
.thenCompose(ignored -> delayAsync(2000)) // Wait for 2 seconds
.thenCompose(ignored -> {
List nodes = List.of(
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle")
.description("Root branch")
.build()
).build(),
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle.Powertrain")
.description("Powertrain branch")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.description("Engine RPM")
.dataType(NodeDataType.DOUBLE)
.unit("rpm")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.description("Vehicle Speed")
.dataType(NodeDataType.DOUBLE)
.unit("km/h")
.build()
).build()
);
CreateSignalCatalogRequest request = CreateSignalCatalogRequest.builder()
.name(signalCatalogName)
.nodes(nodes)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createSignalCatalog(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ValidationException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Error creating the catalog", cause));
}
} else {
result.complete(response.arn());
}
});
return result;
});
}
/**
* Delays the execution of the current thread asynchronously for the specified duration.
*
* @param millis the duration of the delay in milliseconds
* @return a {@link CompletableFuture} that completes after the specified delay
*/
private static CompletableFuture delayAsync(long millis) {
return CompletableFuture.runAsync(() -> {
try {
Thread.sleep(millis);
} catch (InterruptedException e) {
throw new CompletionException("Sleep interrupted", e);
}
});
}
/**
* Deletes the specified signal catalog.
*
* @param signalCatalogName the name of the signal catalog to delete
* @return a {@link CompletableFuture} representing the asynchronous operation.
*/
public static CompletableFuture deleteSignalCatalogIfExistsAsync(String signalCatalogName) {
DeleteSignalCatalogRequest request = DeleteSignalCatalogRequest.builder()
.name(signalCatalogName)
.build();
return getAsyncClient().deleteSignalCatalog(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw new CompletionException(new RuntimeException("Signal Catalog not found: " + signalCatalogName));
}
throw new RuntimeException("Failed to delete signal catalog: " + signalCatalogName, cause);
}
return null;
});
}
/**
* Creates a new decoder manifest.
*
* @param name the name of the decoder manifest
* @param modelManifestArn the ARN of the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created decoder manifest
*/
public CompletableFuture createDecoderManifestAsync(String name, String modelManifestArn) {
String interfaceId = "can0";
NetworkInterface networkInterface = NetworkInterface.builder()
.interfaceId(interfaceId)
.type(NetworkInterfaceType.CAN_INTERFACE)
.canInterface(CanInterface.builder()
.name("canInterface0")
.protocolName("CAN")
.protocolVersion("1.0")
.build())
.build();
// Vehicle.Powertrain.EngineRPM decoder.
SignalDecoder engineRpmDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(100)
.isBigEndian(false)
.isSigned(false)
.startBit(0)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
// Vehicle.Powertrain.VehicleSpeed decoder.
SignalDecoder vehicleSpeedDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(101)
.isBigEndian(false)
.isSigned(false)
.startBit(16)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
CreateDecoderManifestRequest request = CreateDecoderManifestRequest.builder()
.name(name)
.modelManifestArn(modelManifestArn)
.networkInterfaces(List.of(networkInterface))
.signalDecoders(List.of(engineRpmDecoder, vehicleSpeedDecoder))
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof DecoderManifestValidationException) {
result.completeExceptionally(new CompletionException("The request contains signal decoders with validation errors: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create decoder manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
/**
* Deletes a decoder manifest.
*
* @param name the name of the decoder manifest to delete
* @return a {@link CompletableFuture} that completes when the decoder manifest has been deleted
*/
public CompletableFuture deleteDecoderManifestAsync(String name) {
return getAsyncClient().deleteDecoderManifest(DeleteDecoderManifestRequest.builder().name(name).build())
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the decoder manifest: " + cause);
}
return null;
});
}
/**
* Deletes a vehicle with the specified name.
*
* @param vecName the name of the vehicle to be deleted
* @return a {@link CompletableFuture} that completes when the vehicle has been deleted
*/
public CompletableFuture deleteVehicleAsync(String vecName) {
DeleteVehicleRequest request = DeleteVehicleRequest.builder()
.vehicleName(vecName)
.build();
return getAsyncClient().deleteVehicle(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the vehicle: " + cause);
}
return null;
});
}
/**
* Updates the model manifest.
*
* @param name the name of the model manifest to update
*/
public void updateModelManifestAsync(String name) {
UpdateModelManifestRequest request = UpdateModelManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
getAsyncClient().updateModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update model manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
/**
* Updates the decoder manifest with the given name.
*
* @param name the name of the decoder manifest to update
* @return a {@link CompletableFuture} that completes when the update operation is finished
*/
public CompletableFuture updateDecoderManifestAsync(String name) {
UpdateDecoderManifestRequest request = UpdateDecoderManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
return getAsyncClient().updateDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update decoder manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
/**
* Creates a new vehicle in the system.
*
* @param vecName the name of the vehicle to be created
* @param manifestArn the Amazon Resource Name (ARN) of the model manifest for the vehicle
* @param decArn the Amazon Resource Name (ARN) of the decoder manifest for the vehicle
* @return a {@link CompletableFuture} that completes when the vehicle has been created, or throws a
*/
public CompletableFuture createVehicleAsync(String vecName, String manifestArn, String decArn) {
CreateVehicleRequest request = CreateVehicleRequest.builder()
.vehicleName(vecName)
.modelManifestArn(manifestArn)
.decoderManifestArn(decArn)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Failed to create vehicle: " + cause.getMessage(), cause));
}
} else {
logger.info("Vehicle '{}' created successfully.", vecName);
result.complete(null); // mark future as complete
}
});
return result;
}
/**
* Waits for the decoder manifest to become active.
*
* @param decoderName the name of the decoder to wait for
* @return a {@link CompletableFuture} that completes when the decoder manifest becomes active, or exceptionally if an error occurs or the manifest becomes invalid
*/
public CompletableFuture waitForDecoderManifestActiveAsync(String decoderName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info(" Elapsed: 0s | Decoder Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Check status every 5 seconds
if (elapsed % 5 == 0) {
GetDecoderManifestRequest request = GetDecoderManifestRequest.builder()
.name(decoderName)
.build();
getAsyncClient().getDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Decoder manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling decoder manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\r Elapsed: {}s | Decoder Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\r Elapsed: {}s | Decoder Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Decoder manifest became INVALID. Cannot proceed."));
} else {
logger.info("\r⏱ Elapsed: {}s | Decoder Status: {}", elapsed, status);
}
});
} else {
logger.info("\r Elapsed: {}s | Decoder Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
/**
* Waits for the specified model manifest to become active.
*
* @param manifestName the name of the model manifest to wait for
*/
public CompletableFuture waitForModelManifestActiveAsync(String manifestName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info("Elapsed: 0s | Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Only check status every 5 seconds
if (elapsed % 5 == 0) {
GetModelManifestRequest request = GetModelManifestRequest.builder()
.name(manifestName)
.build();
getAsyncClient().getModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Model manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling model manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\rElapsed: {}s | Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\rElapsed: {}s | Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Model manifest became INVALID. Cannot proceed."));
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, status);
}
});
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
/**
* Fetches the details of a vehicle.
*
* @param vehicleName the name of the vehicle to fetch details for
* @return a {@link CompletableFuture} that completes when the vehicle details have been fetched
*/
public CompletableFuture getVehicleDetailsAsync(String vehicleName) {
GetVehicleRequest request = GetVehicleRequest.builder()
.vehicleName(vehicleName)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().getVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause); // don't rewrap
} else {
result.completeExceptionally(new RuntimeException("Failed to fetch vehicle details: " + cause.getMessage(), cause));
}
} else {
Map details = new HashMap<>();
details.put("vehicleName", response.vehicleName());
details.put("arn", response.arn());
details.put("modelManifestArn", response.modelManifestArn());
details.put("decoderManifestArn", response.decoderManifestArn());
details.put("attributes", response.attributes());
details.put("creationTime", response.creationTime().toString());
details.put("lastModificationTime", response.lastModificationTime().toString());
logger.info("Vehicle Details:");
details.forEach((key, value) -> logger.info("• {} : {}", key, value));
result.complete(null); // mark as successful
}
});
return result;
}
/**
* Creates an IoT Thing if it does not already exist.
*
* @param thingName the name of the IoT Thing to create
* @return a {@link CompletableFuture} that completes when the IoT Thing has been created or if it already exists
*/
public CompletableFuture createThingIfNotExistsAsync(String thingName) {
IotAsyncClient iotClient = IotAsyncClient.builder()
.region(Region.US_EAST_1)
.build();
CreateThingRequest request = CreateThingRequest.builder()
.thingName(thingName)
.build();
return iotClient.createThing(request)
.whenComplete((response, exception) -> {
if (exception != null) {
if (exception instanceof ResourceAlreadyExistsException) {
logger.info(" IoT Thing already exists: " + thingName);
} else {
throw new CompletionException("Failed to create IoT Thing: " + thingName, exception);
}
} else {
logger.info("IoT Thing created: " + response.thingName());
}
})
.thenApply(response -> null);
}
/**
* Deletes a model manifest.
*
* @param name the name of the model manifest to delete
* @return a {@link CompletableFuture} that completes when the model manifest has been deleted
*/
public CompletableFuture deleteModelManifestAsync(String name) {
DeleteModelManifestRequest request = DeleteModelManifestRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteModelManifest(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the model manifest: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
/**
* Deletes a signal catalog.
*
* @param name the name of the signal catalog to delete
* @return a {@link CompletableFuture} that completes when the signal catalog is deleted
*/
public CompletableFuture deleteSignalCatalogAsync(String name) {
DeleteSignalCatalogRequest request = DeleteSignalCatalogRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteSignalCatalog(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the signal catalog: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
/**
* Asynchronously retrieves a list of all nodes in the specified signal catalog.
*
* @param signalCatalogName the name of the signal catalog to retrieve nodes for
* @return a {@link CompletableFuture} that, when completed, contains a {@link List} of {@link Node} objects
* representing all the nodes in the specified signal catalog
*/
public CompletableFuture> listSignalCatalogNodeAsync(String signalCatalogName) {
ListSignalCatalogNodesRequest request = ListSignalCatalogNodesRequest.builder()
.name(signalCatalogName)
.build();
List allNodes = new ArrayList<>();
return getAsyncClient().listSignalCatalogNodesPaginator(request)
.subscribe(response -> allNodes.addAll(response.nodes()))
.thenApply(v -> allNodes);
}
/**
* Creates a model manifest.
*
* @param name the name of the model manifest to create
* @param signalCatalogArn the Amazon Resource Name (ARN) of the signal catalog
* @param nodes a list of nodes to include in the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created model manifest
*/
public CompletableFuture createModelManifestAsync(String name,
String signalCatalogArn,
List nodes) {
// Extract the fully qualified names (FQNs) from each Node in the provided list.
List fqnList = nodes.stream()
.map(node -> {
if (node.sensor() != null) {
return node.sensor().fullyQualifiedName();
} else if (node.branch() != null) {
return node.branch().fullyQualifiedName();
} else if (node.attribute() != null) {
return node.attribute().fullyQualifiedName();
} else {
throw new RuntimeException("Unsupported node type");
}
})
.toList();
CreateModelManifestRequest request = CreateModelManifestRequest.builder()
.name(name)
.signalCatalogArn(signalCatalogArn)
.nodes(fqnList)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof InvalidSignalsException) {
result.completeExceptionally(new CompletionException("The request contains signals that aren't valid: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create model manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
/**
* Deletes a fleet based on the provided fleet ID.
*
* @param fleetId the ID of the fleet to be deleted
*/
public CompletableFuture deleteFleetAsync(String fleetId) {
DeleteFleetRequest request = DeleteFleetRequest.builder()
.fleetId(fleetId)
.build();
return getAsyncClient().deleteFleet(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the fleet: " + cause);
}
logger.info("{} was successfully deleted", fleetId);
return null;
});
}
/**
* Creates a new fleet.
*
* @param catARN the Amazon Resource Name (ARN) of the signal catalog to associate with the fleet
* @param fleetId the unique identifier for the fleet
* @return a {@link CompletableFuture} that completes with the ID of the created fleet
*/
public CompletableFuture createFleetAsync(String catARN, String fleetId) {
CreateFleetRequest fleetRequest = CreateFleetRequest.builder()
.fleetId(fleetId)
.signalCatalogArn(catARN)
.description("Built using the AWS For Java V2")
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createFleet(fleetRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("An unexpected error occurred", cause));
}
} else {
result.complete(response.id());
}
});
return result;
}
}
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK for Java 2.x *.
+ [createDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createDecoderManifest)
+ [Créer une flotte](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createFleet)
+ [createModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createModelManifest)
+ [createSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createSignalCatalog)
+ [Créer un véhicule](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createVehicle)
+ [deleteDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteDecoderManifest)
+ [Supprimer la flotte](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteFleet)
+ [deleteModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteModelManifest)
+ [deleteSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteSignalCatalog)
+ [Supprimer le véhicule](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteVehicle)
+ [getDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getDecoderManifest)
+ [getModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getModelManifest)
+ [Obtenir un véhicule](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle)
+ [listSignalCatalogNœuds](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogNodes)
+ [updateDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateDecoderManifest)
+ [updateModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateModelManifest)
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
Exécutez un scénario interactif illustrant AWS IoT SiteWise les fonctionnalités.
```
/**
Before running this Kotlin code example, set up your development environment,
including your credentials.
For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
var scanner = Scanner(System.`in`)
val DASHES = String(CharArray(80)).replace("\u0000", "-")
suspend fun main(args: Array) {
val usage =
"""
Usage:
Where:
signalCatalogName - The name of the Signal Catalog to create (eg, catalog30).
manifestName - The name of the Vehicle Model (Model Manifest) to create (eg, manifest30).
fleetId - The ID of the Fleet to create (eg, fleet30).
vecName - The name of the Vehicle to create (eg, vehicle30).
decName - The name of the Decoder Manifest to create (eg, decManifest30).
""".trimIndent()
if (args.size != 5) {
println(usage)
return
}
val signalCatalogName = args[0]
val manifestName = args[1]
val fleetId = args[2]
val vecName = args[3]
val decName = args[4]
println(
"""
AWS IoT FleetWise is a managed service that simplifies the
process of collecting, organizing, and transmitting vehicle
data to the cloud in near real-time. Designed for automakers
and fleet operators, it allows you to define vehicle models,
specify the exact data you want to collect (such as engine
temperature, speed, or battery status), and send this data to
AWS for analysis. By using intelligent data collection
techniques, IoT FleetWise reduces the volume of data
transmitted by filtering and transforming it at the edge,
helping to minimize bandwidth usage and costs.
At its core, AWS IoT FleetWise helps organizations build
scalable systems for vehicle data management and analytics,
supporting a wide variety of vehicles and sensor configurations.
You can define signal catalogs and decoder manifests that describe
how raw CAN bus signals are translated into readable data, making
the platform highly flexible and extensible. This allows
manufacturers to optimize vehicle performance, improve safety,
and reduce maintenance costs by gaining real-time visibility
into fleet operations.
""".trimIndent(),
)
waitForInputToContinue(scanner)
println(DASHES)
runScenario(signalCatalogName, fleetId, manifestName, decName, vecName)
}
suspend fun runScenario(signalCatalogName: String, fleetIdVal: String, manifestName: String, decName: String, vecName: String) {
println(DASHES)
println("1. Creates a collection of standardized signals that can be reused to create vehicle models")
waitForInputToContinue(scanner)
val signalCatalogArn = createbranchVehicle(signalCatalogName)
println("The collection ARN is $signalCatalogArn")
waitForInputToContinue(scanner)
println(DASHES)
println(DASHES)
println("2. Create a fleet that represents a group of vehicles")
println(
"""
Creating an IoT FleetWise fleet allows you to efficiently collect,
organize, and transfer vehicle data to the cloud, enabling real-time
insights into vehicle performance and health.
It helps reduce data costs by allowing you to filter and prioritize
only the most relevant vehicle signals, supporting advanced analytics
and predictive maintenance use cases.
""".trimIndent(),
)
waitForInputToContinue(scanner)
val fleetid = createFleet(signalCatalogArn, fleetIdVal)
println("The fleet Id is $fleetid")
waitForInputToContinue(scanner)
val nodeList = listSignalCatalogNode(signalCatalogName)
println(DASHES)
println(DASHES)
println("3. Create a model manifest")
println(
"""
An AWS IoT FleetWise manifest defines the structure and
relationships of vehicle data. The model manifest specifies
which signals to collect and how they relate to vehicle systems,
while the decoder manifest defines how to decode raw vehicle data
into meaningful signals.
""".trimIndent(),
)
waitForInputToContinue(scanner)
val nodes = listSignalCatalogNode(signalCatalogName)
val manifestArn = nodes?.let { createModelManifest(manifestName, signalCatalogArn, it) }
println("The manifest ARN is $manifestArn")
println(DASHES)
println(DASHES)
println("4. Create a decoder manifest")
println(
"""
A decoder manifest in AWS IoT FleetWise defines how raw vehicle
data (such as CAN signals) should be interpreted and decoded
into meaningful signals. It acts as a translation layer
that maps vehicle-specific protocols to standardized data formats
using decoding rules. This is crucial for extracting usable
data from different vehicle models, even when their data
formats vary.
""".trimIndent(),
)
waitForInputToContinue(scanner)
val decArn = createDecoderManifest(decName, manifestArn)
println("The decoder manifest ARN is $decArn")
waitForInputToContinue(scanner)
println(DASHES)
println(DASHES)
println("5. Check the status of the model manifest")
println(
"""
The model manifest must be in an ACTIVE state before it can be used
to create or update a vehicle.
""".trimIndent(),
)
waitForInputToContinue(scanner)
updateModelManifest(manifestName)
waitForModelManifestActive(manifestName)
waitForInputToContinue(scanner)
println(DASHES)
println(DASHES)
println("6. Check the status of the decoder")
println(
"""
The decoder manifest must be in an ACTIVE state before it can be used
to create or update a vehicle.
""".trimIndent(),
)
waitForInputToContinue(scanner)
updateDecoderManifest(decName)
waitForDecoderManifestActive(decName)
waitForInputToContinue(scanner)
println(DASHES)
println(DASHES)
println("7. Create an IoT Thing")
println(
"""
AWS IoT FleetWise expects an existing AWS IoT Thing with the same
name as the vehicle name you are passing to createVehicle method.
Before calling createVehicle(), you must create an AWS IoT Thing
with the same name using the AWS IoT Core service.
""".trimIndent(),
)
waitForInputToContinue(scanner)
createThingIfNotExist(vecName)
println(DASHES)
println(DASHES)
println("8. Create a vehicle")
println(
"""
Creating a vehicle in AWS IoT FleetWise allows you to digitally
represent and manage a physical vehicle within the AWS ecosystem.
This enables efficient ingestion, transformation, and transmission
of vehicle telemetry data to the cloud for analysis.
""".trimIndent(),
)
waitForInputToContinue(scanner)
createVehicle(vecName, manifestArn, decArn)
println(DASHES)
println(DASHES)
println("9. Display vehicle details")
waitForInputToContinue(scanner)
getVehicleDetails(vecName)
waitForInputToContinue(scanner)
println(DASHES)
println(DASHES)
println("10. Delete the AWS IoT Fleetwise Assets")
println("Would you like to delete the IoT Fleetwise Assets? (y/n)")
val delAns = scanner.nextLine().trim()
if (delAns.equals("y", ignoreCase = true)) {
deleteVehicle(vecName)
deleteDecoderManifest(decName)
deleteModelManifest(manifestName)
deleteFleet(fleetid)
deleteSignalCatalog(signalCatalogName)
}
println(DASHES)
println(
"""
Thank you for checking out the AWS IoT Fleetwise Service Use demo. We hope you
learned something new, or got some inspiration for your own apps today.
For more AWS code examples, have a look at:
https://docs.aws.amazon.com/code-library/latest/ug/what-is-code-library.html
""".trimIndent(),
)
println(DASHES)
}
suspend fun deleteVehicle(vecName: String) {
val request = DeleteVehicleRequest {
vehicleName = vecName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteVehicle(request)
println("Vehicle $vecName was deleted successfully.")
}
}
suspend fun getVehicleDetails(vehicleNameVal: String) {
val request = GetVehicleRequest {
vehicleName = vehicleNameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.getVehicle(request)
val details = mapOf(
"vehicleName" to response.vehicleName,
"arn" to response.arn,
"modelManifestArn" to response.modelManifestArn,
"decoderManifestArn" to response.decoderManifestArn,
"attributes" to response.attributes.toString(),
"creationTime" to response.creationTime.toString(),
"lastModificationTime" to response.lastModificationTime.toString(),
)
println("Vehicle Details:")
for ((key, value) in details) {
println("• %-20s : %s".format(key, value))
}
}
}
suspend fun createVehicle(vecName: String, manifestArn: String?, decArn: String) {
val request = CreateVehicleRequest {
vehicleName = vecName
modelManifestArn = manifestArn
decoderManifestArn = decArn
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.createVehicle(request)
println("Vehicle $vecName was created successfully.")
}
}
/**
* Creates an IoT Thing if it does not already exist.
*
* @param vecName the name of the IoT Thing to create
*/
suspend fun createThingIfNotExist(vecName: String) {
val request = CreateThingRequest {
thingName = vecName
}
IotClient.fromEnvironment { region = "us-east-1" }.use { client ->
client.createThing(request)
println("The $vecName IoT Thing was successfully created")
}
}
suspend fun updateDecoderManifest(nameVal: String) {
val request = UpdateDecoderManifestRequest {
name = nameVal
status = ManifestStatus.Active
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.updateDecoderManifest(request)
println("$nameVal was successfully updated")
}
}
/**
* Waits for the specified model manifest to become active.
*
* @param decNameVal the name of the model manifest to wait for
*/
suspend fun waitForDecoderManifestActive(decNameVal: String) {
var elapsedSeconds = 0
var lastStatus: ManifestStatus = ManifestStatus.Draft
print("⏳ Elapsed: 0s | Status: DRAFT")
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
while (true) {
delay(1000)
elapsedSeconds++
if (elapsedSeconds % 5 == 0) {
val request = GetDecoderManifestRequest {
name = decNameVal
}
val response = fleetwiseClient.getDecoderManifest(request)
lastStatus = response.status ?: ManifestStatus.Draft
when (lastStatus) {
ManifestStatus.Active -> {
print("\rElapsed: ${elapsedSeconds}s | Status: ACTIVE ✅\n")
return
}
ManifestStatus.Invalid -> {
print("\rElapsed: ${elapsedSeconds}s | Status: INVALID ❌\n")
throw RuntimeException("Model manifest became INVALID. Cannot proceed.")
}
else -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
} else {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
}
}
/**
* Waits for the specified model manifest to become active.
*
* @param manifestName the name of the model manifest to wait for
*/
suspend fun waitForModelManifestActive(manifestNameVal: String) {
var elapsedSeconds = 0
var lastStatus: ManifestStatus = ManifestStatus.Draft
print("⏳ Elapsed: 0s | Status: DRAFT")
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
while (true) {
delay(1000)
elapsedSeconds++
if (elapsedSeconds % 5 == 0) {
val request = GetModelManifestRequest {
name = manifestNameVal
}
val response = fleetwiseClient.getModelManifest(request)
lastStatus = response.status ?: ManifestStatus.Draft
when (lastStatus) {
ManifestStatus.Active -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: ACTIVE ✅\n")
return
}
ManifestStatus.Invalid -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: INVALID ❌\n")
throw RuntimeException("Model manifest became INVALID. Cannot proceed.")
}
else -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
} else {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
}
}
/**
* Updates the model manifest.
*
* @param nameVal the name of the model manifest to update
*/
suspend fun updateModelManifest(nameVal: String) {
val request = UpdateModelManifestRequest {
name = nameVal
status = ManifestStatus.Active
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.updateModelManifest(request)
println("$nameVal was successfully updated")
}
}
suspend fun deleteDecoderManifest(nameVal: String) {
val request = DeleteDecoderManifestRequest {
name = nameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteDecoderManifest(request)
println("$nameVal was successfully deleted")
}
}
/**
* Creates a new decoder manifest.
*
* @param decName the name of the decoder manifest
* @param modelManifestArnVal the ARN of the model manifest
* @return the ARN of the decoder manifest
*/
suspend fun createDecoderManifest(decName: String, modelManifestArnVal: String?): String {
val interfaceIdVal = "can0"
val canInter = CanInterface {
name = "canInterface0"
protocolName = "CAN"
protocolVersion = "1.0"
}
val networkInterface = NetworkInterface {
interfaceId = interfaceIdVal
type = NetworkInterfaceType.CanInterface
canInterface = canInter
}
val carRpmSig = CanSignal {
messageId = 100
isBigEndian = false
isSigned = false
startBit = 16
length = 16
factor = 1.0
offset = 0.0
}
val carSpeedSig = CanSignal {
messageId = 101
isBigEndian = false
isSigned = false
startBit = 0
length = 16
factor = 1.0
offset = 0.0
}
val engineRpmDecoder = SignalDecoder {
fullyQualifiedName = "Vehicle.Powertrain.EngineRPM"
interfaceId = interfaceIdVal
type = SignalDecoderType.CanSignal
canSignal = carRpmSig
}
val vehicleSpeedDecoder = SignalDecoder {
fullyQualifiedName = "Vehicle.Powertrain.VehicleSpeed"
interfaceId = interfaceIdVal
type = SignalDecoderType.CanSignal
canSignal = carSpeedSig
}
val request = CreateDecoderManifestRequest {
name = decName
modelManifestArn = modelManifestArnVal
networkInterfaces = listOf(networkInterface)
signalDecoders = listOf(engineRpmDecoder, vehicleSpeedDecoder)
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createDecoderManifest(request)
return response.arn
}
}
/**
* Deletes a signal catalog.
*
* @param name the name of the signal catalog to delete
*/
suspend fun deleteSignalCatalog(catName: String) {
val request = DeleteSignalCatalogRequest {
name = catName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteSignalCatalog(request)
println(" $catName was successfully deleted")
}
}
/**
* Deletes a fleet based on the provided fleet ID.
*
* @param fleetId the ID of the fleet to be deleted
*/
suspend fun deleteFleet(fleetIdVal: String) {
val request = DeleteFleetRequest {
fleetId = fleetIdVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteFleet(request)
println(" $fleetIdVal was successfully deleted")
}
}
/**
* Deletes a model manifest.
*
* @param nameVal the name of the model manifest to delete
*/
suspend fun deleteModelManifest(nameVal: String) {
val request = DeleteModelManifestRequest {
name = nameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteModelManifest(request)
println(" $nameVal was successfully deleted")
}
}
/**
* Creates a model manifest.
*
* @param name the name of the model manifest to create
* @param signalCatalogArn the Amazon Resource Name (ARN) of the signal catalog
* @param nodes a list of nodes to include in the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created model manifest
*/
suspend fun createModelManifest(nameVal: String, signalCatalogArnVal: String, nodesList: List): String {
val fqnList: List = nodesList.map { node ->
when (node) {
is Node.Sensor -> node.asSensor().fullyQualifiedName
is Node.Branch -> node.asBranch().fullyQualifiedName
else -> throw RuntimeException("Unsupported node type")
}
}
val request = CreateModelManifestRequest {
name = nameVal
signalCatalogArn = signalCatalogArnVal
nodes = fqnList
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createModelManifest(request)
return response.arn
}
}
/**
* Lists the signal catalog nodes asynchronously.
*
* @param signalCatalogName the name of the signal catalog
* @return a CompletableFuture that, when completed, contains a list of nodes in the specified signal catalog
* @throws CompletionException if an exception occurs during the asynchronous operation
*/
suspend fun listSignalCatalogNode(signalCatalogName: String): List? {
val request = ListSignalCatalogNodesRequest {
name = signalCatalogName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.listSignalCatalogNodes(request)
return response.nodes
}
}
/**
* Creates a new fleet.
*
* @param catARN the Amazon Resource Name (ARN) of the signal catalog to associate with the fleet
* @param fleetId the unique identifier for the fleet
* @return the ID of the created fleet
*/
suspend fun createFleet(catARN: String, fleetIdVal: String): String {
val fleetRequest = CreateFleetRequest {
fleetId = fleetIdVal
signalCatalogArn = catARN
description = "Built using the AWS For Kotlin"
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createFleet(fleetRequest)
return response.id
}
}
/**
* Creates a signal catalog.
*
* @param signalCatalogName the name of the signal catalog to create the branch vehicle in
* @return the ARN (Amazon Resource Name) of the created signal catalog
*/
suspend fun createbranchVehicle(signalCatalogName: String): String {
delay(2000) // Wait for 2 seconds
val branchVehicle = Branch {
fullyQualifiedName = "Vehicle"
description = "Root branch"
}
val branchPowertrain = Branch {
fullyQualifiedName = "Vehicle.Powertrain"
description = "Powertrain branch"
}
val sensorRPM = Sensor {
fullyQualifiedName = "Vehicle.Powertrain.EngineRPM"
description = "Engine RPM"
dataType = NodeDataType.Double
unit = "rpm"
}
val sensorKM = Sensor {
fullyQualifiedName = "Vehicle.Powertrain.VehicleSpeed"
description = "Vehicle Speed"
dataType = NodeDataType.Double
unit = "km/h"
}
// Wrap each specific node type (Branch and Sensor) into the sealed Node class
// so they can be included in the CreateSignalCatalogRequest.
val myNodes = listOf(
Node.Branch(branchVehicle),
Node.Branch(branchPowertrain),
Node.Sensor(sensorRPM),
Node.Sensor(sensorKM),
)
val request = CreateSignalCatalogRequest {
name = signalCatalogName
nodes = myNodes
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createSignalCatalog(request)
return response.arn
}
}
private fun waitForInputToContinue(scanner: Scanner) {
while (true) {
println("")
println("Enter 'c' followed by to continue:")
val input = scanner.nextLine()
if (input.trim { it <= ' ' }.equals("c", ignoreCase = true)) {
println("Continuing with the program...")
println("")
break
} else {
println("Invalid input. Please try again.")
}
}
}
```
+ Pour plus de détails sur l’API, consultez les rubriques suivantes dans la *Référence des API du kit AWS SDK pour Kotlin*.
+ [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Créer une flotte](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [createModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [createSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Créer un véhicule](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Supprimer la flotte](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [deleteModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [deleteSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Supprimer le véhicule](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [getDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [getModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Obtenir un véhicule](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [listSignalCatalogNœuds](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [updateDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [updateModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
------
# Actions d' AWS IoT FleetWise utilisation AWS SDKs
Les exemples de code suivants montrent comment effectuer des AWS IoT FleetWise actions individuelles avec AWS SDKs. Chaque exemple inclut un lien vers GitHub, où vous pouvez trouver des instructions pour configurer et exécuter le code.
Les exemples suivants incluent uniquement les actions les plus couramment utilisées. Pour obtenir la liste complète, consultez la [Référence des API AWS IoT FleetWise](https://docs.aws.amazon.com/iot-fleetwise/latest/APIReference/Welcome.html).
**Topics**
+ [`createDecoderManifest`](iotfleetwise_example_iotfleetwise_CreateDecoderManifest_section.md)
+ [`createFleet`](iotfleetwise_example_iotfleetwise_CreateFleet_section.md)
+ [`createModelManifest`](iotfleetwise_example_iotfleetwise_CreateModelManifest_section.md)
+ [`createSignalCatalog`](iotfleetwise_example_iotfleetwise_CreateSignalCatalog_section.md)
+ [`createVehicle`](iotfleetwise_example_iotfleetwise_CreateVehicle_section.md)
+ [`deleteDecoderManifest`](iotfleetwise_example_iotfleetwise_DeleteDecoderManifest_section.md)
+ [`deleteFleet`](iotfleetwise_example_iotfleetwise_DeleteFleet_section.md)
+ [`deleteModelManifest`](iotfleetwise_example_iotfleetwise_DeleteModelManifest_section.md)
+ [`deleteSignalCatalog`](iotfleetwise_example_iotfleetwise_DeleteSignalCatalog_section.md)
+ [`deleteVehicle`](iotfleetwise_example_iotfleetwise_DeleteVehicle_section.md)
+ [`getDecoderManifest`](iotfleetwise_example_iotfleetwise_GetDecoderManifest_section.md)
+ [`getModelManifest`](iotfleetwise_example_iotfleetwise_GetModelManifest_section.md)
+ [`getVehicle`](iotfleetwise_example_iotfleetwise_GetVehicle_section.md)
+ [`listSignalCatalogNodes`](iotfleetwise_example_iotfleetwise_ListSignalCatalogNodes_section.md)
+ [`updateDecoderManifest`](iotfleetwise_example_iotfleetwise_UpdateDecoderManifest_section.md)
+ [`updateModelManifest`](iotfleetwise_example_iotfleetwise_UpdateModelManifest_section.md)
# Utilisation `createDecoderManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `createDecoderManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Creates a new decoder manifest.
*
* @param name the name of the decoder manifest
* @param modelManifestArn the ARN of the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created decoder manifest
*/
public CompletableFuture createDecoderManifestAsync(String name, String modelManifestArn) {
String interfaceId = "can0";
NetworkInterface networkInterface = NetworkInterface.builder()
.interfaceId(interfaceId)
.type(NetworkInterfaceType.CAN_INTERFACE)
.canInterface(CanInterface.builder()
.name("canInterface0")
.protocolName("CAN")
.protocolVersion("1.0")
.build())
.build();
// Vehicle.Powertrain.EngineRPM decoder.
SignalDecoder engineRpmDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(100)
.isBigEndian(false)
.isSigned(false)
.startBit(0)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
// Vehicle.Powertrain.VehicleSpeed decoder.
SignalDecoder vehicleSpeedDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(101)
.isBigEndian(false)
.isSigned(false)
.startBit(16)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
CreateDecoderManifestRequest request = CreateDecoderManifestRequest.builder()
.name(name)
.modelManifestArn(modelManifestArn)
.networkInterfaces(List.of(networkInterface))
.signalDecoders(List.of(engineRpmDecoder, vehicleSpeedDecoder))
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof DecoderManifestValidationException) {
result.completeExceptionally(new CompletionException("The request contains signal decoders with validation errors: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create decoder manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
```
+ Pour plus de détails sur l'API, reportez-vous [createDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createDecoderManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Creates a new decoder manifest.
*
* @param decName the name of the decoder manifest
* @param modelManifestArnVal the ARN of the model manifest
* @return the ARN of the decoder manifest
*/
suspend fun createDecoderManifest(decName: String, modelManifestArnVal: String?): String {
val interfaceIdVal = "can0"
val canInter = CanInterface {
name = "canInterface0"
protocolName = "CAN"
protocolVersion = "1.0"
}
val networkInterface = NetworkInterface {
interfaceId = interfaceIdVal
type = NetworkInterfaceType.CanInterface
canInterface = canInter
}
val carRpmSig = CanSignal {
messageId = 100
isBigEndian = false
isSigned = false
startBit = 16
length = 16
factor = 1.0
offset = 0.0
}
val carSpeedSig = CanSignal {
messageId = 101
isBigEndian = false
isSigned = false
startBit = 0
length = 16
factor = 1.0
offset = 0.0
}
val engineRpmDecoder = SignalDecoder {
fullyQualifiedName = "Vehicle.Powertrain.EngineRPM"
interfaceId = interfaceIdVal
type = SignalDecoderType.CanSignal
canSignal = carRpmSig
}
val vehicleSpeedDecoder = SignalDecoder {
fullyQualifiedName = "Vehicle.Powertrain.VehicleSpeed"
interfaceId = interfaceIdVal
type = SignalDecoderType.CanSignal
canSignal = carSpeedSig
}
val request = CreateDecoderManifestRequest {
name = decName
modelManifestArn = modelManifestArnVal
networkInterfaces = listOf(networkInterface)
signalDecoders = listOf(engineRpmDecoder, vehicleSpeedDecoder)
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createDecoderManifest(request)
return response.arn
}
}
```
+ Pour plus de détails sur l'API, consultez [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `createFleet` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `createFleet`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Creates a new fleet.
*
* @param catARN the Amazon Resource Name (ARN) of the signal catalog to associate with the fleet
* @param fleetId the unique identifier for the fleet
* @return a {@link CompletableFuture} that completes with the ID of the created fleet
*/
public CompletableFuture createFleetAsync(String catARN, String fleetId) {
CreateFleetRequest fleetRequest = CreateFleetRequest.builder()
.fleetId(fleetId)
.signalCatalogArn(catARN)
.description("Built using the AWS For Java V2")
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createFleet(fleetRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("An unexpected error occurred", cause));
}
} else {
result.complete(response.id());
}
});
return result;
}
```
+ Pour plus de détails sur l’API, consultez [createFleet](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createFleet) dans la *Référence des API du kit AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Creates a new fleet.
*
* @param catARN the Amazon Resource Name (ARN) of the signal catalog to associate with the fleet
* @param fleetId the unique identifier for the fleet
* @return the ID of the created fleet
*/
suspend fun createFleet(catARN: String, fleetIdVal: String): String {
val fleetRequest = CreateFleetRequest {
fleetId = fleetIdVal
signalCatalogArn = catARN
description = "Built using the AWS For Kotlin"
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createFleet(fleetRequest)
return response.id
}
}
```
+ Pour plus de détails sur l’API, consultez [createFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans la *Référence des API du kit AWS SDK pour Kotlin*.
------
# Utilisation `createModelManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `createModelManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Creates a model manifest.
*
* @param name the name of the model manifest to create
* @param signalCatalogArn the Amazon Resource Name (ARN) of the signal catalog
* @param nodes a list of nodes to include in the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created model manifest
*/
public CompletableFuture createModelManifestAsync(String name,
String signalCatalogArn,
List nodes) {
// Extract the fully qualified names (FQNs) from each Node in the provided list.
List fqnList = nodes.stream()
.map(node -> {
if (node.sensor() != null) {
return node.sensor().fullyQualifiedName();
} else if (node.branch() != null) {
return node.branch().fullyQualifiedName();
} else if (node.attribute() != null) {
return node.attribute().fullyQualifiedName();
} else {
throw new RuntimeException("Unsupported node type");
}
})
.toList();
CreateModelManifestRequest request = CreateModelManifestRequest.builder()
.name(name)
.signalCatalogArn(signalCatalogArn)
.nodes(fqnList)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof InvalidSignalsException) {
result.completeExceptionally(new CompletionException("The request contains signals that aren't valid: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create model manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
```
+ Pour plus de détails sur l'API, reportez-vous [createModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createModelManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Creates a model manifest.
*
* @param name the name of the model manifest to create
* @param signalCatalogArn the Amazon Resource Name (ARN) of the signal catalog
* @param nodes a list of nodes to include in the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created model manifest
*/
suspend fun createModelManifest(nameVal: String, signalCatalogArnVal: String, nodesList: List): String {
val fqnList: List = nodesList.map { node ->
when (node) {
is Node.Sensor -> node.asSensor().fullyQualifiedName
is Node.Branch -> node.asBranch().fullyQualifiedName
else -> throw RuntimeException("Unsupported node type")
}
}
val request = CreateModelManifestRequest {
name = nameVal
signalCatalogArn = signalCatalogArnVal
nodes = fqnList
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createModelManifest(request)
return response.arn
}
}
```
+ Pour plus de détails sur l'API, consultez [createModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `createSignalCatalog` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `createSignalCatalog`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Creates a signal catalog.
*
* @param signalCatalogName the name of the signal catalog to be created
* @return a {@link CompletableFuture} that completes with the Amazon Resource Name (ARN) of the created signal catalog
*/
public CompletableFuture createSignalCatalogAsync(String signalCatalogName) {
return deleteSignalCatalogIfExistsAsync(signalCatalogName)
.thenCompose(ignored -> delayAsync(2000)) // Wait for 2 seconds
.thenCompose(ignored -> {
List nodes = List.of(
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle")
.description("Root branch")
.build()
).build(),
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle.Powertrain")
.description("Powertrain branch")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.description("Engine RPM")
.dataType(NodeDataType.DOUBLE)
.unit("rpm")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.description("Vehicle Speed")
.dataType(NodeDataType.DOUBLE)
.unit("km/h")
.build()
).build()
);
CreateSignalCatalogRequest request = CreateSignalCatalogRequest.builder()
.name(signalCatalogName)
.nodes(nodes)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createSignalCatalog(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ValidationException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Error creating the catalog", cause));
}
} else {
result.complete(response.arn());
}
});
return result;
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [createSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createSignalCatalog)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Creates a signal catalog.
*
* @param signalCatalogName the name of the signal catalog to create the branch vehicle in
* @return the ARN (Amazon Resource Name) of the created signal catalog
*/
suspend fun createbranchVehicle(signalCatalogName: String): String {
delay(2000) // Wait for 2 seconds
val branchVehicle = Branch {
fullyQualifiedName = "Vehicle"
description = "Root branch"
}
val branchPowertrain = Branch {
fullyQualifiedName = "Vehicle.Powertrain"
description = "Powertrain branch"
}
val sensorRPM = Sensor {
fullyQualifiedName = "Vehicle.Powertrain.EngineRPM"
description = "Engine RPM"
dataType = NodeDataType.Double
unit = "rpm"
}
val sensorKM = Sensor {
fullyQualifiedName = "Vehicle.Powertrain.VehicleSpeed"
description = "Vehicle Speed"
dataType = NodeDataType.Double
unit = "km/h"
}
// Wrap each specific node type (Branch and Sensor) into the sealed Node class
// so they can be included in the CreateSignalCatalogRequest.
val myNodes = listOf(
Node.Branch(branchVehicle),
Node.Branch(branchPowertrain),
Node.Sensor(sensorRPM),
Node.Sensor(sensorKM),
)
val request = CreateSignalCatalogRequest {
name = signalCatalogName
nodes = myNodes
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.createSignalCatalog(request)
return response.arn
}
}
```
+ Pour plus de détails sur l'API, consultez [createSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `createVehicle` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `createVehicle`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Creates a new vehicle in the system.
*
* @param vecName the name of the vehicle to be created
* @param manifestArn the Amazon Resource Name (ARN) of the model manifest for the vehicle
* @param decArn the Amazon Resource Name (ARN) of the decoder manifest for the vehicle
* @return a {@link CompletableFuture} that completes when the vehicle has been created, or throws a
*/
public CompletableFuture createVehicleAsync(String vecName, String manifestArn, String decArn) {
CreateVehicleRequest request = CreateVehicleRequest.builder()
.vehicleName(vecName)
.modelManifestArn(manifestArn)
.decoderManifestArn(decArn)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Failed to create vehicle: " + cause.getMessage(), cause));
}
} else {
logger.info("Vehicle '{}' created successfully.", vecName);
result.complete(null); // mark future as complete
}
});
return result;
}
```
+ Pour plus de détails sur l’API, consultez [createVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createVehicle) dans la *Référence des API du kit AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
suspend fun createVehicle(vecName: String, manifestArn: String?, decArn: String) {
val request = CreateVehicleRequest {
vehicleName = vecName
modelManifestArn = manifestArn
decoderManifestArn = decArn
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.createVehicle(request)
println("Vehicle $vecName was created successfully.")
}
}
```
+ Pour plus de détails sur l’API, consultez [createVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans la *Référence des API du kit AWS SDK pour Kotlin*.
------
# Utilisation `deleteDecoderManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `deleteDecoderManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Deletes a decoder manifest.
*
* @param name the name of the decoder manifest to delete
* @return a {@link CompletableFuture} that completes when the decoder manifest has been deleted
*/
public CompletableFuture deleteDecoderManifestAsync(String name) {
return getAsyncClient().deleteDecoderManifest(DeleteDecoderManifestRequest.builder().name(name).build())
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the decoder manifest: " + cause);
}
return null;
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [deleteDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteDecoderManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
suspend fun deleteDecoderManifest(nameVal: String) {
val request = DeleteDecoderManifestRequest {
name = nameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteDecoderManifest(request)
println("$nameVal was successfully deleted")
}
}
```
+ Pour plus de détails sur l'API, consultez [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `deleteFleet` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `deleteFleet`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Deletes a fleet based on the provided fleet ID.
*
* @param fleetId the ID of the fleet to be deleted
*/
public CompletableFuture deleteFleetAsync(String fleetId) {
DeleteFleetRequest request = DeleteFleetRequest.builder()
.fleetId(fleetId)
.build();
return getAsyncClient().deleteFleet(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the fleet: " + cause);
}
logger.info("{} was successfully deleted", fleetId);
return null;
});
}
```
+ Pour plus de détails sur l’API, consultez [deleteFleet](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteFleet) dans la *Référence des API du kit AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Deletes a fleet based on the provided fleet ID.
*
* @param fleetId the ID of the fleet to be deleted
*/
suspend fun deleteFleet(fleetIdVal: String) {
val request = DeleteFleetRequest {
fleetId = fleetIdVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteFleet(request)
println(" $fleetIdVal was successfully deleted")
}
}
```
+ Pour plus de détails sur l’API, consultez [deleteFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans la *Référence des API du kit AWS SDK pour Kotlin*.
------
# Utilisation `deleteModelManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `deleteModelManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Deletes a model manifest.
*
* @param name the name of the model manifest to delete
* @return a {@link CompletableFuture} that completes when the model manifest has been deleted
*/
public CompletableFuture deleteModelManifestAsync(String name) {
DeleteModelManifestRequest request = DeleteModelManifestRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteModelManifest(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the model manifest: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [deleteModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteModelManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Deletes a model manifest.
*
* @param nameVal the name of the model manifest to delete
*/
suspend fun deleteModelManifest(nameVal: String) {
val request = DeleteModelManifestRequest {
name = nameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteModelManifest(request)
println(" $nameVal was successfully deleted")
}
}
```
+ Pour plus de détails sur l'API, consultez [deleteModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `deleteSignalCatalog` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `deleteSignalCatalog`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Deletes a signal catalog.
*
* @param name the name of the signal catalog to delete
* @return a {@link CompletableFuture} that completes when the signal catalog is deleted
*/
public CompletableFuture deleteSignalCatalogAsync(String name) {
DeleteSignalCatalogRequest request = DeleteSignalCatalogRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteSignalCatalog(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the signal catalog: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
```
+ Pour plus de détails sur l'API, reportez-vous [deleteSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteSignalCatalog)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Deletes a signal catalog.
*
* @param name the name of the signal catalog to delete
*/
suspend fun deleteSignalCatalog(catName: String) {
val request = DeleteSignalCatalogRequest {
name = catName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteSignalCatalog(request)
println(" $catName was successfully deleted")
}
}
```
+ Pour plus de détails sur l'API, consultez [deleteSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `deleteVehicle` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `deleteVehicle`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Deletes a vehicle with the specified name.
*
* @param vecName the name of the vehicle to be deleted
* @return a {@link CompletableFuture} that completes when the vehicle has been deleted
*/
public CompletableFuture deleteVehicleAsync(String vecName) {
DeleteVehicleRequest request = DeleteVehicleRequest.builder()
.vehicleName(vecName)
.build();
return getAsyncClient().deleteVehicle(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the vehicle: " + cause);
}
return null;
});
}
```
+ Pour plus de détails sur l’API, consultez [deleteVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteVehicle) dans la *Référence des API du kit AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
suspend fun deleteVehicle(vecName: String) {
val request = DeleteVehicleRequest {
vehicleName = vecName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.deleteVehicle(request)
println("Vehicle $vecName was deleted successfully.")
}
}
```
+ Pour plus de détails sur l’API, consultez [deleteVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans la *Référence des API du kit AWS SDK pour Kotlin*.
------
# Utilisation `getDecoderManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `getDecoderManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Waits for the decoder manifest to become active.
*
* @param decoderName the name of the decoder to wait for
* @return a {@link CompletableFuture} that completes when the decoder manifest becomes active, or exceptionally if an error occurs or the manifest becomes invalid
*/
public CompletableFuture waitForDecoderManifestActiveAsync(String decoderName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info(" Elapsed: 0s | Decoder Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Check status every 5 seconds
if (elapsed % 5 == 0) {
GetDecoderManifestRequest request = GetDecoderManifestRequest.builder()
.name(decoderName)
.build();
getAsyncClient().getDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Decoder manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling decoder manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\r Elapsed: {}s | Decoder Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\r Elapsed: {}s | Decoder Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Decoder manifest became INVALID. Cannot proceed."));
} else {
logger.info("\r⏱ Elapsed: {}s | Decoder Status: {}", elapsed, status);
}
});
} else {
logger.info("\r Elapsed: {}s | Decoder Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
```
+ Pour plus de détails sur l'API, reportez-vous [getDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getDecoderManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Waits for the specified model manifest to become active.
*
* @param decNameVal the name of the model manifest to wait for
*/
suspend fun waitForDecoderManifestActive(decNameVal: String) {
var elapsedSeconds = 0
var lastStatus: ManifestStatus = ManifestStatus.Draft
print("⏳ Elapsed: 0s | Status: DRAFT")
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
while (true) {
delay(1000)
elapsedSeconds++
if (elapsedSeconds % 5 == 0) {
val request = GetDecoderManifestRequest {
name = decNameVal
}
val response = fleetwiseClient.getDecoderManifest(request)
lastStatus = response.status ?: ManifestStatus.Draft
when (lastStatus) {
ManifestStatus.Active -> {
print("\rElapsed: ${elapsedSeconds}s | Status: ACTIVE ✅\n")
return
}
ManifestStatus.Invalid -> {
print("\rElapsed: ${elapsedSeconds}s | Status: INVALID ❌\n")
throw RuntimeException("Model manifest became INVALID. Cannot proceed.")
}
else -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
} else {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
}
}
```
+ Pour plus de détails sur l'API, consultez [getDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `getModelManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `getModelManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Waits for the specified model manifest to become active.
*
* @param manifestName the name of the model manifest to wait for
*/
public CompletableFuture waitForModelManifestActiveAsync(String manifestName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info("Elapsed: 0s | Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Only check status every 5 seconds
if (elapsed % 5 == 0) {
GetModelManifestRequest request = GetModelManifestRequest.builder()
.name(manifestName)
.build();
getAsyncClient().getModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Model manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling model manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\rElapsed: {}s | Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\rElapsed: {}s | Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Model manifest became INVALID. Cannot proceed."));
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, status);
}
});
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
```
+ Pour plus de détails sur l'API, reportez-vous [getModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getModelManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Waits for the specified model manifest to become active.
*
* @param manifestName the name of the model manifest to wait for
*/
suspend fun waitForModelManifestActive(manifestNameVal: String) {
var elapsedSeconds = 0
var lastStatus: ManifestStatus = ManifestStatus.Draft
print("⏳ Elapsed: 0s | Status: DRAFT")
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
while (true) {
delay(1000)
elapsedSeconds++
if (elapsedSeconds % 5 == 0) {
val request = GetModelManifestRequest {
name = manifestNameVal
}
val response = fleetwiseClient.getModelManifest(request)
lastStatus = response.status ?: ManifestStatus.Draft
when (lastStatus) {
ManifestStatus.Active -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: ACTIVE ✅\n")
return
}
ManifestStatus.Invalid -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: INVALID ❌\n")
throw RuntimeException("Model manifest became INVALID. Cannot proceed.")
}
else -> {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
} else {
print("\r Elapsed: ${elapsedSeconds}s | Status: $lastStatus")
}
}
}
}
```
+ Pour plus de détails sur l'API, consultez [getModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `getVehicle` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `getVehicle`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Fetches the details of a vehicle.
*
* @param vehicleName the name of the vehicle to fetch details for
* @return a {@link CompletableFuture} that completes when the vehicle details have been fetched
*/
public CompletableFuture getVehicleDetailsAsync(String vehicleName) {
GetVehicleRequest request = GetVehicleRequest.builder()
.vehicleName(vehicleName)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().getVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause); // don't rewrap
} else {
result.completeExceptionally(new RuntimeException("Failed to fetch vehicle details: " + cause.getMessage(), cause));
}
} else {
Map details = new HashMap<>();
details.put("vehicleName", response.vehicleName());
details.put("arn", response.arn());
details.put("modelManifestArn", response.modelManifestArn());
details.put("decoderManifestArn", response.decoderManifestArn());
details.put("attributes", response.attributes());
details.put("creationTime", response.creationTime().toString());
details.put("lastModificationTime", response.lastModificationTime().toString());
logger.info("Vehicle Details:");
details.forEach((key, value) -> logger.info("• {} : {}", key, value));
result.complete(null); // mark as successful
}
});
return result;
}
```
+ Pour plus de détails sur l’API, consultez [getVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle) dans la *Référence des API du kit AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
suspend fun getVehicleDetails(vehicleNameVal: String) {
val request = GetVehicleRequest {
vehicleName = vehicleNameVal
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.getVehicle(request)
val details = mapOf(
"vehicleName" to response.vehicleName,
"arn" to response.arn,
"modelManifestArn" to response.modelManifestArn,
"decoderManifestArn" to response.decoderManifestArn,
"attributes" to response.attributes.toString(),
"creationTime" to response.creationTime.toString(),
"lastModificationTime" to response.lastModificationTime.toString(),
)
println("Vehicle Details:")
for ((key, value) in details) {
println("• %-20s : %s".format(key, value))
}
}
}
```
+ Pour plus de détails sur l’API, consultez [getVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) dans la *Référence des API du kit AWS SDK pour Kotlin*.
------
# Utilisation `listSignalCatalogNodes` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `listSignalCatalogNodes`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Asynchronously retrieves a list of all nodes in the specified signal catalog.
*
* @param signalCatalogName the name of the signal catalog to retrieve nodes for
* @return a {@link CompletableFuture} that, when completed, contains a {@link List} of {@link Node} objects
* representing all the nodes in the specified signal catalog
*/
public CompletableFuture> listSignalCatalogNodeAsync(String signalCatalogName) {
ListSignalCatalogNodesRequest request = ListSignalCatalogNodesRequest.builder()
.name(signalCatalogName)
.build();
List allNodes = new ArrayList<>();
return getAsyncClient().listSignalCatalogNodesPaginator(request)
.subscribe(response -> allNodes.addAll(response.nodes()))
.thenApply(v -> allNodes);
}
```
+ Pour plus de détails sur l'API, consultez la section [listSignalCatalogNodes](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogNodes) dans le *AWS SDK for Java 2.x manuel de référence des API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Lists the signal catalog nodes asynchronously.
*
* @param signalCatalogName the name of the signal catalog
* @return a CompletableFuture that, when completed, contains a list of nodes in the specified signal catalog
* @throws CompletionException if an exception occurs during the asynchronous operation
*/
suspend fun listSignalCatalogNode(signalCatalogName: String): List? {
val request = ListSignalCatalogNodesRequest {
name = signalCatalogName
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
val response = fleetwiseClient.listSignalCatalogNodes(request)
return response.nodes
}
}
```
+ Pour plus de détails sur l'API, voir [listSignalCatalogNodes](https://sdk.amazonaws.com/kotlin/api/latest/index.html) in *AWS SDK for Kotlin API reference*.
------
# Utilisation `updateDecoderManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `updateDecoderManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Updates the decoder manifest with the given name.
*
* @param name the name of the decoder manifest to update
* @return a {@link CompletableFuture} that completes when the update operation is finished
*/
public CompletableFuture updateDecoderManifestAsync(String name) {
UpdateDecoderManifestRequest request = UpdateDecoderManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
return getAsyncClient().updateDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update decoder manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
```
+ Pour plus de détails sur l'API, reportez-vous [updateDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateDecoderManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
suspend fun updateDecoderManifest(nameVal: String) {
val request = UpdateDecoderManifestRequest {
name = nameVal
status = ManifestStatus.Active
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.updateDecoderManifest(request)
println("$nameVal was successfully updated")
}
}
```
+ Pour plus de détails sur l'API, consultez [updateDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------
# Utilisation `updateModelManifest` avec un AWS SDK
Les exemples de code suivants illustrent comment utiliser `updateModelManifest`.
Les exemples d’actions sont des extraits de code de programmes de plus grande envergure et doivent être exécutés en contexte. Vous pouvez voir cette action en contexte dans l’exemple de code suivant :
+ [Principes de base](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK pour Java 2.x**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
```
/**
* Updates the model manifest.
*
* @param name the name of the model manifest to update
*/
public void updateModelManifestAsync(String name) {
UpdateModelManifestRequest request = UpdateModelManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
getAsyncClient().updateModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update model manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
```
+ Pour plus de détails sur l'API, reportez-vous [updateModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateModelManifest)à la section *Référence des AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK pour Kotlin**
Il y en a plus à ce sujet GitHub. Trouvez l’exemple complet et découvrez comment le configurer et l’exécuter dans le [référentiel d’exemples de code AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
```
/**
* Updates the model manifest.
*
* @param nameVal the name of the model manifest to update
*/
suspend fun updateModelManifest(nameVal: String) {
val request = UpdateModelManifestRequest {
name = nameVal
status = ManifestStatus.Active
}
IotFleetWiseClient.fromEnvironment { region = "us-east-1" }.use { fleetwiseClient ->
fleetwiseClient.updateModelManifest(request)
println("$nameVal was successfully updated")
}
}
```
+ Pour plus de détails sur l'API, consultez [updateModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la section *AWS SDK pour la référence de l'API Kotlin*.
------