Hay más ejemplos de AWS SDK disponibles en el GitHub repositorio de [ejemplos de AWS Doc SDK](https://github.com/awsdocs/aws-doc-sdk-examples).
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
# Ejemplos de código para usar AWS IoT FleetWise AWS SDKs
Los siguientes ejemplos de código muestran cómo usarlo AWS IoT FleetWise con un kit de desarrollo de AWS software (SDK).
Los *conceptos básicos* son ejemplos de código que muestran cómo realizar las operaciones esenciales dentro de un servicio.
Las *acciones* son extractos de código de programas más grandes y deben ejecutarse en contexto. Mientras las acciones muestran cómo llamar a las distintas funciones de servicio, es posible ver las acciones en contexto en los escenarios relacionados.
**Más recursos**
+ **[AWS IoT FleetWise Guía para desarrolladores](https://docs.aws.amazon.com/iot-fleetwise/latest/developerguide/what-is-fleetwise.html)**: más información sobre AWS IoT FleetWise.
+ **[AWS IoT FleetWise Referencia de la API](https://docs.aws.amazon.com/iot-fleetwise/latest/APIReference/Welcome.html)**: detalles sobre todas AWS IoT FleetWise las acciones disponibles.
+ **[AWS Centro para desarrolladores](https://aws.amazon.com/developer/code-examples/?awsf.sdk-code-examples-product=product%23)**: ejemplos de código que puedes filtrar por categoría o por búsqueda de texto completo.
+ **[AWS Ejemplos de SDK](https://github.com/awsdocs/aws-doc-sdk-examples)**: GitHub repositorio con código completo en los idiomas preferidos. Incluye instrucciones para configurar y ejecutar el código.
**Contents**
+ [Conceptos básicos](iotfleetwise_code_examples_basics.md)
+ [Hola AWS IoT FleetWise](iotfleetwise_example_iotfleetwise_Hello_section.md)
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
+ [Acciones](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)
# Ejemplos básicos de uso AWS IoT FleetWise AWS SDKs
Los siguientes ejemplos de código muestran cómo utilizar los conceptos básicos de AWS IoT FleetWise with AWS SDKs.
**Contents**
+ [Hola AWS IoT FleetWise](iotfleetwise_example_iotfleetwise_Hello_section.md)
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
+ [Acciones](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)
# Hola AWS IoT FleetWise
En los siguientes ejemplos de código se muestra cómo empezar a utilizar AWS IoT FleetWise.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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);
}
}
}
```
+ Para obtener más información sobre la API, consulta [listSignalCatalogsPaginator](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogsPaginator) en la referencia de la *AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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("---------------")
}
}
}
}
}
```
+ Para obtener más información sobre la API, consulta [listSignalCatalogsPaginator](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en el *AWS SDK para ver la referencia sobre la API de Kotlin*.
------
# Aprenda los conceptos básicos de cómo usar un AWS IoT FleetWise SDK AWS
En el siguiente ejemplo de código, se muestra cómo:
+ Crear una colección de señales estandarizadas.
+ Crear una flota que represente un grupo de vehículos.
+ Crear un manifiesto del modelo.
+ Cree un manifiesto del decodificador.
+ Comprobar el estado del manifiesto del modelo.
+ Comprobar el estado del descodificador.
+ Crear un objeto de IoT.
+ Creación de un vehículo
+ Mostrar los detalles del vehículo.
+ Elimine los AWS IoT FleetWise activos.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
Ejecute un escenario interactivo que demuestre AWS IoT SiteWise las funciones.
```
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.");
}
}
}
}
```
Una clase contenedora para los métodos AWS IoT FleetWise del 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;
}
}
```
+ Para obtener detalles sobre la API, consulte los siguientes temas en la *Referencia de la API de AWS SDK for Java 2.x *.
+ [createDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createDecoderManifest)
+ [CreateFleet](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)
+ [Crear vehículo](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)
+ [Eliminar flota](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)
+ [Eliminar vehículo](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)
+ [Obtenga un vehículo](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle)
+ [listSignalCatalogNodos](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 para Kotlin**
Hay más información. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
Ejecute un escenario interactivo que demuestre AWS IoT SiteWise las funciones.
```
/**
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.")
}
}
}
```
+ Para obtener detalles sobre la API, consulte los siguientes temas en la *Referencia de la API de AWS SDK para Kotlin*.
+ [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Crea una flota](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)
+ [Crear vehículo](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [Eliminar flota](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)
+ [Eliminar vehículo](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)
+ [Obtenga un vehículo](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [listSignalCatalogNodos](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)
------
# Acciones de uso AWS IoT FleetWise AWS SDKs
Los siguientes ejemplos de código muestran cómo realizar AWS IoT FleetWise acciones individuales con AWS SDKs. Cada ejemplo incluye un enlace a GitHub, donde puede encontrar instrucciones para configurar y ejecutar el código.
Los siguientes ejemplos incluyen solo las acciones que se utilizan con mayor frecuencia. Para ver una lista completa, consulte la [Referencia de la API de 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)
# `createDecoderManifest`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `createDecoderManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener más información sobre la API, consulta [createDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createDecoderManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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
}
}
```
+ Para obtener más información sobre la API, consulta [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `createFleet` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `createFleet`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener información sobre la API, consulte [createFleet](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createFleet) en la *Referencia de la API de AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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
}
}
```
+ Para obtener información sobre la API, consulte [createFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en la *Referencia de la API de AWS SDK para Kotlin*.
------
# `createModelManifest`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `createModelManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener más información sobre la API, consulta [createModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createModelManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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
}
}
```
+ Para obtener más información sobre la API, consulta [createModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `createSignalCatalog` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `createSignalCatalog`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener más información sobre la API, consulta [createSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createSignalCatalog)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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
}
}
```
+ Para obtener más información sobre la API, consulta [createSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `createVehicle` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `createVehicle`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener información sobre la API, consulte [createVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createVehicle) en la *Referencia de la API de AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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.")
}
}
```
+ Para obtener información sobre la API, consulte [createVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en la *Referencia de la API de AWS SDK para Kotlin*.
------
# `deleteDecoderManifest`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `deleteDecoderManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener más información sobre la API, consulta [deleteDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteDecoderManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener más información sobre la API, consulta [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `deleteFleet` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `deleteFleet`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener información sobre la API, consulte [deleteFleet](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteFleet) en la *Referencia de la API de AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener información sobre la API, consulte [deleteFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en la *Referencia de la API de AWS SDK para Kotlin*.
------
# `deleteModelManifest`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `deleteModelManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener más información sobre la API, consulta [deleteModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteModelManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener más información sobre la API, consulta [deleteModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `deleteSignalCatalog` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `deleteSignalCatalog`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener más información sobre la API, consulta [deleteSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteSignalCatalog)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener más información sobre la API, consulta [deleteSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `deleteVehicle` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `deleteVehicle`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
});
}
```
+ Para obtener información sobre la API, consulte [deleteVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteVehicle) en la *Referencia de la API de AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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.")
}
}
```
+ Para obtener información sobre la API, consulte [deleteVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en la *Referencia de la API de AWS SDK para Kotlin*.
------
# `getDecoderManifest`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `getDecoderManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener más información sobre la API, consulta [getDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getDecoderManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
}
}
```
+ Para obtener más información sobre la API, consulta [getDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `getModelManifest` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `getModelManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener más información sobre la API, consulta [getModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getModelManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
}
}
```
+ Para obtener más información sobre la API, consulta [getModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `getVehicle` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `getVehicle`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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;
}
```
+ Para obtener información sobre la API, consulte [getVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle) en la *Referencia de la API de AWS SDK for Java 2.x *.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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))
}
}
}
```
+ Para obtener información sobre la API, consulte [getVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) en la *Referencia de la API de AWS SDK para Kotlin*.
------
# `listSignalCatalogNodes`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `listSignalCatalogNodes`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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);
}
```
+ Para obtener más información sobre la API, consulta la [listSignalCatalogsección Nodes](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogNodes) in *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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
}
}
```
+ Para obtener más información sobre la API, consulta la *referencia sobre [listSignalCataloglos nodos](https://sdk.amazonaws.com/kotlin/api/latest/index.html)AWS del SDK para la API de Kotlin*.
------
# `updateDecoderManifest`Utilízalo con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `updateDecoderManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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);
}
```
+ Para obtener más información sobre la API, consulta [updateDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateDecoderManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener más información sobre la API, consulta [updateDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `updateModelManifest` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `updateModelManifest`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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);
}
```
+ Para obtener más información sobre la API, consulta [updateModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateModelManifest)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de 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")
}
}
```
+ Para obtener más información sobre la API, consulta [updateModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------