Add digital twin lifecycle sample #14744
Conversation
abhipsaMisra
changed the title
abhipsaMisra
force-pushed
the
feature/adt/abmisr/twinSample
branch
from
2c34588
to
81835bd
Compare
abhipsaMisra
requested review from
azabbasi,
barustum,
bikamani,
drwill-ms,
timtay-microsoft and
vinagesh
as code owners
| .forEach((twinId, twinContent) -> { | ||
| // Call APIs to delete all relationships. | ||
| client.listRelationships(twinId, BasicRelationship.class) | ||
| .doOnComplete(deleteRelationshipsSemaphore::release) |
There was a problem hiding this comment.
This runnable is executed when the flux completes successfully.
| // Call APIs to delete all relationships. | ||
| client.listRelationships(twinId, BasicRelationship.class) | ||
| .doOnComplete(deleteRelationshipsSemaphore::release) | ||
| .doOnError(throwable -> { |
There was a problem hiding this comment.
This function is executed when the flux completes with an error
| @@ -6,7 +6,9 @@ | |||
| import com.azure.core.http.policy.HttpLogDetailLevel; | |||
There was a problem hiding this comment.
I think we should have an Async Suffix in the file name to indicate that we are using Async APIs for this sample.
| public static void createTwins() throws IOException, InterruptedException { | ||
| System.out.println("CREATE DIGITAL TWINS"); | ||
| Map<String, String> twins = FileHelper.loadAllFilesInPath(TwinsPath); | ||
| final Semaphore createTwinsSemaphore = new Semaphore(0); |
There was a problem hiding this comment.
To understand why do we need semaphore here? Do we have some limitations for parallel operations?
There was a problem hiding this comment.
No, not really. The semaphore is to ensure that we do not exit before the async operation has completed. We start all async operations and then release the semaphore only once the async call has completed.
That way, the subsequent operations are executed after the previous call has completed -> similar to doing a await on a Task.
Update ReplicationLinks.json in 2021-02-01-preview (Azure#14744) * update ReplicationLinks.json in 2021-02-01-preview * update json file * update examples/ReplicationLinkGet.json
Update ReplicationLinks.json in 2021-02-01-preview (Azure#14744) * update ReplicationLinks.json in 2021-02-01-preview * update json file * update examples/ReplicationLinkGet.json
Add code for sample cleanup and creation of digital twin.
TODO: