Ada lebih banyak contoh AWS SDK yang tersedia di repo Contoh [SDK AWS Doc](https://github.com/awsdocs/aws-doc-sdk-examples). GitHub
Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Contoh kode untuk AWS IoT FleetWise menggunakan AWS SDKs
Contoh kode berikut menunjukkan cara menggunakan AWS IoT FleetWise kit pengembangan AWS perangkat lunak (SDK).
*Dasar-dasar* adalah contoh kode yang menunjukkan kepada Anda bagaimana melakukan operasi penting dalam suatu layanan.
*Tindakan* merupakan kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Sementara tindakan menunjukkan cara memanggil fungsi layanan individual, Anda dapat melihat tindakan dalam konteks dalam skenario terkait.
**Sumber daya lainnya**
+ **[AWS IoT FleetWise Panduan Pengembang](https://docs.aws.amazon.com/iot-fleetwise/latest/developerguide/what-is-fleetwise.html)** - Informasi lebih lanjut tentang AWS IoT FleetWise.
+ **[AWS IoT FleetWise Referensi API](https://docs.aws.amazon.com/iot-fleetwise/latest/APIReference/Welcome.html)** — Detail tentang semua AWS IoT FleetWise tindakan yang tersedia.
+ **[AWS Pusat Pengembang](https://aws.amazon.com/developer/code-examples/?awsf.sdk-code-examples-product=product%23)** - Contoh kode yang dapat Anda filter berdasarkan kategori atau pencarian teks lengkap.
+ **[AWS Contoh SDK](https://github.com/awsdocs/aws-doc-sdk-examples)** — GitHub repo dengan kode lengkap dalam bahasa pilihan. Termasuk instruksi untuk mengatur dan menjalankan kode.
**Contents**
+ [Hal-hal mendasar](iotfleetwise_code_examples_basics.md)
+ [Halo AWS IoT FleetWise](iotfleetwise_example_iotfleetwise_Hello_section.md)
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
+ [Tindakan](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)
# Contoh dasar untuk AWS IoT FleetWise menggunakan AWS SDKs
Contoh kode berikut menunjukkan cara menggunakan dasar-dasar AWS IoT FleetWise dengan AWS SDKs.
**Contents**
+ [Halo AWS IoT FleetWise](iotfleetwise_example_iotfleetwise_Hello_section.md)
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
+ [Tindakan](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)
# Halo AWS IoT FleetWise
Contoh kode berikut menunjukkan cara untuk mulai menggunakan AWS IoT FleetWise.
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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);
}
}
}
```
+ Untuk detail API, lihat [listSignalCatalogsPaginator di Referensi AWS SDK for Java 2.x](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogsPaginator) *API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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("---------------")
}
}
}
}
}
```
+ Untuk detail API, lihat [listSignalCatalogsPaginator](https://sdk.amazonaws.com/kotlin/api/latest/index.html) di *AWS SDK untuk referensi API Kotlin*.
------
# Pelajari dasar-dasar AWS IoT FleetWise dengan AWS SDK
Contoh-contoh kode berikut menunjukkan cara:
+ Buat kumpulan sinyal standar.
+ Buat armada yang mewakili sekelompok kendaraan.
+ Buat manifes model.
+ Buat manifes decoder.
+ Periksa status manifes model.
+ Periksa status decoder.
+ Buat IoT Thing.
+ Buat kendaraan.
+ Tampilkan detail kendaraan.
+ Hapus AWS IoT FleetWise Aset.
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/iotfleetwise#code-examples).
Jalankan skenario interaktif yang menunjukkan AWS IoT SiteWise fitur.
```
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.");
}
}
}
}
```
Kelas pembungkus untuk metode AWS IoT FleetWise SDK.
```
public class FleetwiseActions {
private static final Logger logger = LoggerFactory.getLogger(FleetwiseActions.class);
private static IoTFleetWiseAsyncClient ioTFleetWiseAsyncClient;
private static IoTFleetWiseAsyncClient getAsyncClient() {
if (ioTFleetWiseAsyncClient == null) {
SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder()
.maxConcurrency(100)
.connectionTimeout(Duration.ofSeconds(60))
.readTimeout(Duration.ofSeconds(60))
.writeTimeout(Duration.ofSeconds(60))
.build();
ClientOverrideConfiguration overrideConfig = ClientOverrideConfiguration.builder()
.apiCallTimeout(Duration.ofMinutes(2))
.apiCallAttemptTimeout(Duration.ofSeconds(90))
.retryStrategy(RetryMode.STANDARD)
.build();
ioTFleetWiseAsyncClient = IoTFleetWiseAsyncClient.builder()
.httpClient(httpClient)
.overrideConfiguration(overrideConfig)
.build();
}
return ioTFleetWiseAsyncClient;
}
/**
* Creates a signal catalog.
*
* @param signalCatalogName the name of the signal catalog to be created
* @return a {@link CompletableFuture} that completes with the Amazon Resource Name (ARN) of the created signal catalog
*/
public CompletableFuture createSignalCatalogAsync(String signalCatalogName) {
return deleteSignalCatalogIfExistsAsync(signalCatalogName)
.thenCompose(ignored -> delayAsync(2000)) // Wait for 2 seconds
.thenCompose(ignored -> {
List nodes = List.of(
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle")
.description("Root branch")
.build()
).build(),
Node.builder().branch(
Branch.builder()
.fullyQualifiedName("Vehicle.Powertrain")
.description("Powertrain branch")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.description("Engine RPM")
.dataType(NodeDataType.DOUBLE)
.unit("rpm")
.build()
).build(),
Node.builder().sensor(
Sensor.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.description("Vehicle Speed")
.dataType(NodeDataType.DOUBLE)
.unit("km/h")
.build()
).build()
);
CreateSignalCatalogRequest request = CreateSignalCatalogRequest.builder()
.name(signalCatalogName)
.nodes(nodes)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createSignalCatalog(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ValidationException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Error creating the catalog", cause));
}
} else {
result.complete(response.arn());
}
});
return result;
});
}
/**
* Delays the execution of the current thread asynchronously for the specified duration.
*
* @param millis the duration of the delay in milliseconds
* @return a {@link CompletableFuture} that completes after the specified delay
*/
private static CompletableFuture delayAsync(long millis) {
return CompletableFuture.runAsync(() -> {
try {
Thread.sleep(millis);
} catch (InterruptedException e) {
throw new CompletionException("Sleep interrupted", e);
}
});
}
/**
* Deletes the specified signal catalog.
*
* @param signalCatalogName the name of the signal catalog to delete
* @return a {@link CompletableFuture} representing the asynchronous operation.
*/
public static CompletableFuture deleteSignalCatalogIfExistsAsync(String signalCatalogName) {
DeleteSignalCatalogRequest request = DeleteSignalCatalogRequest.builder()
.name(signalCatalogName)
.build();
return getAsyncClient().deleteSignalCatalog(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw new CompletionException(new RuntimeException("Signal Catalog not found: " + signalCatalogName));
}
throw new RuntimeException("Failed to delete signal catalog: " + signalCatalogName, cause);
}
return null;
});
}
/**
* Creates a new decoder manifest.
*
* @param name the name of the decoder manifest
* @param modelManifestArn the ARN of the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created decoder manifest
*/
public CompletableFuture createDecoderManifestAsync(String name, String modelManifestArn) {
String interfaceId = "can0";
NetworkInterface networkInterface = NetworkInterface.builder()
.interfaceId(interfaceId)
.type(NetworkInterfaceType.CAN_INTERFACE)
.canInterface(CanInterface.builder()
.name("canInterface0")
.protocolName("CAN")
.protocolVersion("1.0")
.build())
.build();
// Vehicle.Powertrain.EngineRPM decoder.
SignalDecoder engineRpmDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.EngineRPM")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(100)
.isBigEndian(false)
.isSigned(false)
.startBit(0)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
// Vehicle.Powertrain.VehicleSpeed decoder.
SignalDecoder vehicleSpeedDecoder = SignalDecoder.builder()
.fullyQualifiedName("Vehicle.Powertrain.VehicleSpeed")
.interfaceId(interfaceId)
.type(SignalDecoderType.CAN_SIGNAL)
.canSignal(CanSignal.builder()
.messageId(101)
.isBigEndian(false)
.isSigned(false)
.startBit(16)
.length(16)
.factor(1.0)
.offset(0.0)
.build())
.build();
CreateDecoderManifestRequest request = CreateDecoderManifestRequest.builder()
.name(name)
.modelManifestArn(modelManifestArn)
.networkInterfaces(List.of(networkInterface))
.signalDecoders(List.of(engineRpmDecoder, vehicleSpeedDecoder))
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof DecoderManifestValidationException) {
result.completeExceptionally(new CompletionException("The request contains signal decoders with validation errors: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create decoder manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
/**
* Deletes a decoder manifest.
*
* @param name the name of the decoder manifest to delete
* @return a {@link CompletableFuture} that completes when the decoder manifest has been deleted
*/
public CompletableFuture deleteDecoderManifestAsync(String name) {
return getAsyncClient().deleteDecoderManifest(DeleteDecoderManifestRequest.builder().name(name).build())
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the decoder manifest: " + cause);
}
return null;
});
}
/**
* Deletes a vehicle with the specified name.
*
* @param vecName the name of the vehicle to be deleted
* @return a {@link CompletableFuture} that completes when the vehicle has been deleted
*/
public CompletableFuture deleteVehicleAsync(String vecName) {
DeleteVehicleRequest request = DeleteVehicleRequest.builder()
.vehicleName(vecName)
.build();
return getAsyncClient().deleteVehicle(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the vehicle: " + cause);
}
return null;
});
}
/**
* Updates the model manifest.
*
* @param name the name of the model manifest to update
*/
public void updateModelManifestAsync(String name) {
UpdateModelManifestRequest request = UpdateModelManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
getAsyncClient().updateModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update model manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
/**
* Updates the decoder manifest with the given name.
*
* @param name the name of the decoder manifest to update
* @return a {@link CompletableFuture} that completes when the update operation is finished
*/
public CompletableFuture updateDecoderManifestAsync(String name) {
UpdateDecoderManifestRequest request = UpdateDecoderManifestRequest.builder()
.name(name)
.status(ManifestStatus.ACTIVE)
.build();
return getAsyncClient().updateDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
throw new CompletionException("Failed to update decoder manifest: " + exception.getMessage(), exception);
}
})
.thenApply(response -> null);
}
/**
* Creates a new vehicle in the system.
*
* @param vecName the name of the vehicle to be created
* @param manifestArn the Amazon Resource Name (ARN) of the model manifest for the vehicle
* @param decArn the Amazon Resource Name (ARN) of the decoder manifest for the vehicle
* @return a {@link CompletableFuture} that completes when the vehicle has been created, or throws a
*/
public CompletableFuture createVehicleAsync(String vecName, String manifestArn, String decArn) {
CreateVehicleRequest request = CreateVehicleRequest.builder()
.vehicleName(vecName)
.modelManifestArn(manifestArn)
.decoderManifestArn(decArn)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("Failed to create vehicle: " + cause.getMessage(), cause));
}
} else {
logger.info("Vehicle '{}' created successfully.", vecName);
result.complete(null); // mark future as complete
}
});
return result;
}
/**
* Waits for the decoder manifest to become active.
*
* @param decoderName the name of the decoder to wait for
* @return a {@link CompletableFuture} that completes when the decoder manifest becomes active, or exceptionally if an error occurs or the manifest becomes invalid
*/
public CompletableFuture waitForDecoderManifestActiveAsync(String decoderName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info(" Elapsed: 0s | Decoder Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Check status every 5 seconds
if (elapsed % 5 == 0) {
GetDecoderManifestRequest request = GetDecoderManifestRequest.builder()
.name(decoderName)
.build();
getAsyncClient().getDecoderManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Decoder manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling decoder manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\r Elapsed: {}s | Decoder Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\r Elapsed: {}s | Decoder Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Decoder manifest became INVALID. Cannot proceed."));
} else {
logger.info("\r⏱ Elapsed: {}s | Decoder Status: {}", elapsed, status);
}
});
} else {
logger.info("\r Elapsed: {}s | Decoder Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
/**
* Waits for the specified model manifest to become active.
*
* @param manifestName the name of the model manifest to wait for
*/
public CompletableFuture waitForModelManifestActiveAsync(String manifestName) {
CompletableFuture result = new CompletableFuture<>();
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
AtomicInteger secondsElapsed = new AtomicInteger(0);
AtomicReference lastStatus = new AtomicReference<>(ManifestStatus.DRAFT);
logger.info("Elapsed: 0s | Status: DRAFT");
final Runnable pollTask = new Runnable() {
@Override
public void run() {
int elapsed = secondsElapsed.incrementAndGet();
// Only check status every 5 seconds
if (elapsed % 5 == 0) {
GetModelManifestRequest request = GetModelManifestRequest.builder()
.name(manifestName)
.build();
getAsyncClient().getModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
scheduler.shutdown();
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(new RuntimeException("Model manifest not found: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new RuntimeException("Error while polling model manifest status: " + exception.getMessage(), exception));
}
return;
}
ManifestStatus status = response.status();
lastStatus.set(status);
if (status == ManifestStatus.ACTIVE) {
logger.info("\rElapsed: {}s | Status: ACTIVE", elapsed);
scheduler.shutdown();
result.complete(null);
} else if (status == ManifestStatus.INVALID) {
logger.info("\rElapsed: {}s | Status: INVALID", elapsed);
scheduler.shutdown();
result.completeExceptionally(new RuntimeException("Model manifest became INVALID. Cannot proceed."));
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, status);
}
});
} else {
logger.info("\rElapsed: {}s | Status: {}", elapsed, lastStatus.get());
}
}
};
// Start the task with an initial delay of 1 second, and repeat every second
scheduler.scheduleAtFixedRate(pollTask, 1, 1, TimeUnit.SECONDS);
return result;
}
/**
* Fetches the details of a vehicle.
*
* @param vehicleName the name of the vehicle to fetch details for
* @return a {@link CompletableFuture} that completes when the vehicle details have been fetched
*/
public CompletableFuture getVehicleDetailsAsync(String vehicleName) {
GetVehicleRequest request = GetVehicleRequest.builder()
.vehicleName(vehicleName)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().getVehicle(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception instanceof CompletionException ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause); // don't rewrap
} else {
result.completeExceptionally(new RuntimeException("Failed to fetch vehicle details: " + cause.getMessage(), cause));
}
} else {
Map details = new HashMap<>();
details.put("vehicleName", response.vehicleName());
details.put("arn", response.arn());
details.put("modelManifestArn", response.modelManifestArn());
details.put("decoderManifestArn", response.decoderManifestArn());
details.put("attributes", response.attributes());
details.put("creationTime", response.creationTime().toString());
details.put("lastModificationTime", response.lastModificationTime().toString());
logger.info("Vehicle Details:");
details.forEach((key, value) -> logger.info("• {} : {}", key, value));
result.complete(null); // mark as successful
}
});
return result;
}
/**
* Creates an IoT Thing if it does not already exist.
*
* @param thingName the name of the IoT Thing to create
* @return a {@link CompletableFuture} that completes when the IoT Thing has been created or if it already exists
*/
public CompletableFuture createThingIfNotExistsAsync(String thingName) {
IotAsyncClient iotClient = IotAsyncClient.builder()
.region(Region.US_EAST_1)
.build();
CreateThingRequest request = CreateThingRequest.builder()
.thingName(thingName)
.build();
return iotClient.createThing(request)
.whenComplete((response, exception) -> {
if (exception != null) {
if (exception instanceof ResourceAlreadyExistsException) {
logger.info(" IoT Thing already exists: " + thingName);
} else {
throw new CompletionException("Failed to create IoT Thing: " + thingName, exception);
}
} else {
logger.info("IoT Thing created: " + response.thingName());
}
})
.thenApply(response -> null);
}
/**
* Deletes a model manifest.
*
* @param name the name of the model manifest to delete
* @return a {@link CompletableFuture} that completes when the model manifest has been deleted
*/
public CompletableFuture deleteModelManifestAsync(String name) {
DeleteModelManifestRequest request = DeleteModelManifestRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteModelManifest(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the model manifest: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
/**
* Deletes a signal catalog.
*
* @param name the name of the signal catalog to delete
* @return a {@link CompletableFuture} that completes when the signal catalog is deleted
*/
public CompletableFuture deleteSignalCatalogAsync(String name) {
DeleteSignalCatalogRequest request = DeleteSignalCatalogRequest.builder()
.name(name)
.build();
return getAsyncClient().deleteSignalCatalog(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the signal catalog: " + cause);
}
logger.info("{} was successfully deleted", name);
return null;
});
}
/**
* Asynchronously retrieves a list of all nodes in the specified signal catalog.
*
* @param signalCatalogName the name of the signal catalog to retrieve nodes for
* @return a {@link CompletableFuture} that, when completed, contains a {@link List} of {@link Node} objects
* representing all the nodes in the specified signal catalog
*/
public CompletableFuture> listSignalCatalogNodeAsync(String signalCatalogName) {
ListSignalCatalogNodesRequest request = ListSignalCatalogNodesRequest.builder()
.name(signalCatalogName)
.build();
List allNodes = new ArrayList<>();
return getAsyncClient().listSignalCatalogNodesPaginator(request)
.subscribe(response -> allNodes.addAll(response.nodes()))
.thenApply(v -> allNodes);
}
/**
* Creates a model manifest.
*
* @param name the name of the model manifest to create
* @param signalCatalogArn the Amazon Resource Name (ARN) of the signal catalog
* @param nodes a list of nodes to include in the model manifest
* @return a {@link CompletableFuture} that completes with the ARN of the created model manifest
*/
public CompletableFuture createModelManifestAsync(String name,
String signalCatalogArn,
List nodes) {
// Extract the fully qualified names (FQNs) from each Node in the provided list.
List fqnList = nodes.stream()
.map(node -> {
if (node.sensor() != null) {
return node.sensor().fullyQualifiedName();
} else if (node.branch() != null) {
return node.branch().fullyQualifiedName();
} else if (node.attribute() != null) {
return node.attribute().fullyQualifiedName();
} else {
throw new RuntimeException("Unsupported node type");
}
})
.toList();
CreateModelManifestRequest request = CreateModelManifestRequest.builder()
.name(name)
.signalCatalogArn(signalCatalogArn)
.nodes(fqnList)
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createModelManifest(request)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof InvalidSignalsException) {
result.completeExceptionally(new CompletionException("The request contains signals that aren't valid: " + cause.getMessage(), cause));
} else {
result.completeExceptionally(new CompletionException("Failed to create model manifest: " + exception.getMessage(), exception));
}
} else {
result.complete(response.arn()); // Complete successfully with the ARN
}
});
return result;
}
/**
* Deletes a fleet based on the provided fleet ID.
*
* @param fleetId the ID of the fleet to be deleted
*/
public CompletableFuture deleteFleetAsync(String fleetId) {
DeleteFleetRequest request = DeleteFleetRequest.builder()
.fleetId(fleetId)
.build();
return getAsyncClient().deleteFleet(request)
.handle((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
throw (ResourceNotFoundException) cause;
}
throw new RuntimeException("Failed to delete the fleet: " + cause);
}
logger.info("{} was successfully deleted", fleetId);
return null;
});
}
/**
* Creates a new fleet.
*
* @param catARN the Amazon Resource Name (ARN) of the signal catalog to associate with the fleet
* @param fleetId the unique identifier for the fleet
* @return a {@link CompletableFuture} that completes with the ID of the created fleet
*/
public CompletableFuture createFleetAsync(String catARN, String fleetId) {
CreateFleetRequest fleetRequest = CreateFleetRequest.builder()
.fleetId(fleetId)
.signalCatalogArn(catARN)
.description("Built using the AWS For Java V2")
.build();
CompletableFuture result = new CompletableFuture<>();
getAsyncClient().createFleet(fleetRequest)
.whenComplete((response, exception) -> {
if (exception != null) {
Throwable cause = exception.getCause() != null ? exception.getCause() : exception;
if (cause instanceof ResourceNotFoundException) {
result.completeExceptionally(cause);
} else {
result.completeExceptionally(new RuntimeException("An unexpected error occurred", cause));
}
} else {
result.complete(response.id());
}
});
return result;
}
}
```
+ Untuk detail API, lihat topik berikut di *Referensi API 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)
+ [CreateVehicle](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)
+ [DeleteFleet](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)
+ [DeleteveHicle](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)
+ [GetVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle)
+ [listSignalCatalogNode](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 untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/iotfleetwise#code-examples).
Jalankan skenario interaktif yang menunjukkan AWS IoT SiteWise fitur.
```
/**
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.")
}
}
}
```
+ Untuk detail API, lihat topik berikut di *Referensi API AWS SDK untuk Kotlin*.
+ [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [CreateFleet](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)
+ [CreateVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DeleteFleet](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)
+ [DeleteveHicle](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)
+ [GetVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [listSignalCatalogNode](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)
------
# Tindakan untuk AWS IoT FleetWise menggunakan AWS SDKs
Contoh kode berikut menunjukkan bagaimana melakukan AWS IoT FleetWise tindakan individu dengan AWS SDKs. Setiap contoh menyertakan tautan ke GitHub, di mana Anda dapat menemukan instruksi untuk mengatur dan menjalankan kode.
Contoh berikut hanya mencakup tindakan yang paling umum digunakan. Untuk daftar lengkapnya, lihat [Referensi AWS IoT FleetWise API](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)
# Gunakan `createDecoderManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`createDecoderManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ Untuk detail API, lihat [createDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createDecoderManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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
}
}
```
+ Untuk detail API, lihat [createDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `createFleet` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`createFleet`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ *Untuk detail API, lihat [createFleet di Referensi](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createFleet) API.AWS SDK for Java 2.x *
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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
}
}
```
+ Untuk detail API, lihat [createFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) di *AWS SDK* untuk referensi API Kotlin.
------
# Gunakan `createModelManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`createModelManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ Untuk detail API, lihat [createModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createModelManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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
}
}
```
+ Untuk detail API, lihat [createModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `createSignalCatalog` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`createSignalCatalog`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ Untuk detail API, lihat [createSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createSignalCatalog)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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
}
}
```
+ Untuk detail API, lihat [createSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `createVehicle` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`createVehicle`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ *Untuk detail API, lihat [CreateVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/createVehicle) di Referensi API.AWS SDK for Java 2.x *
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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.")
}
}
```
+ Untuk detail API, lihat [CreateVehicle di *AWS SDK* untuk referensi API Kotlin](https://sdk.amazonaws.com/kotlin/api/latest/index.html).
------
# Gunakan `deleteDecoderManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`deleteDecoderManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ Untuk detail API, lihat [deleteDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteDecoderManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [deleteDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `deleteFleet` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`deleteFleet`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ *Untuk detail API, lihat [DeleteFleet](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteFleet) di AWS SDK for Java 2.x Referensi API.*
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [DeleteFleet](https://sdk.amazonaws.com/kotlin/api/latest/index.html) di *AWS SDK untuk* referensi API Kotlin.
------
# Gunakan `deleteModelManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`deleteModelManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ Untuk detail API, lihat [deleteModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteModelManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [deleteModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `deleteSignalCatalog` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`deleteSignalCatalog`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ Untuk detail API, lihat [deleteSignalCatalog](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteSignalCatalog)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [deleteSignalCatalog](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `deleteVehicle` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`deleteVehicle`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
});
}
```
+ *Untuk detail API, lihat [DeleteVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/deleteVehicle) di Referensi API.AWS SDK for Java 2.x *
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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.")
}
}
```
+ Untuk detail API, lihat [DeleteVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) di *AWS SDK* untuk referensi API Kotlin.
------
# Gunakan `getDecoderManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`getDecoderManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ Untuk detail API, lihat [getDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getDecoderManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
}
}
```
+ Untuk detail API, lihat [getDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `getModelManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`getModelManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ Untuk detail API, lihat [getModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getModelManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
}
}
```
+ Untuk detail API, lihat [getModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `getVehicle` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`getVehicle`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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;
}
```
+ Untuk detail API, lihat [GetVehicle](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/getVehicle) di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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))
}
}
}
```
+ Untuk detail API, lihat [getVehicle](https://sdk.amazonaws.com/kotlin/api/latest/index.html) in *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `listSignalCatalogNodes` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`listSignalCatalogNodes`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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);
}
```
+ Untuk detail API, lihat [listSignalCatalogNode](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/listSignalCatalogNodes) di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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
}
}
```
+ Untuk detail API, lihat [listSignalCatalogNode](https://sdk.amazonaws.com/kotlin/api/latest/index.html) di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `updateDecoderManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`updateDecoderManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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);
}
```
+ Untuk detail API, lihat [updateDecoderManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateDecoderManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [updateDecoderManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------
# Gunakan `updateModelManifest` dengan AWS SDK
Contoh kode berikut menunjukkan cara menggunakan`updateModelManifest`.
Contoh tindakan adalah kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Anda dapat melihat tindakan ini dalam konteks dalam contoh kode berikut:
+ [Pelajari dasar-dasarnya](iotfleetwise_example_iotfleetwise_Scenario_section.md)
------
#### [ Java ]
**SDK untuk Java 2.x**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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);
}
```
+ Untuk detail API, lihat [updateModelManifest](https://docs.aws.amazon.com/goto/SdkForJavaV2/iotfleetwise-2021-06-17/updateModelManifest)di *Referensi AWS SDK for Java 2.x API*.
------
#### [ Kotlin ]
**SDK untuk Kotlin**
Ada lebih banyak tentang GitHub. Temukan contoh lengkapnya dan pelajari cara mengatur dan menjalankannya di [Repositori Contoh Kode 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")
}
}
```
+ Untuk detail API, lihat [updateModelManifest](https://sdk.amazonaws.com/kotlin/api/latest/index.html)di *AWS SDK untuk referensi API Kotlin*.
------