sendConnectorEvent
inline suspend fun IotManagedIntegrationsClient.sendConnectorEvent(crossinline block: SendConnectorEventRequest.Builder.() -> Unit): SendConnectorEventResponse
Relays third-party device events for a connector such as a new device or a device state change event.
Samples
import aws.sdk.kotlin.services.iotmanagedintegrations.model.ConnectorEventOperation
import aws.sdk.kotlin.services.iotmanagedintegrations.model.Device
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReport
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportAttribute
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportEndpoint
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterEndpoint
import aws.smithy.kotlin.runtime.content.Document
import aws.smithy.kotlin.runtime.content.buildDocument
fun main() {
//sampleStart
// SendConnectorEvent happy path for device discovery
val resp = iotManagedIntegrationsClient.sendConnectorEvent {
connectorId = "MockConnectorId"
userId = "MockThirdPartyUserId"
operation = ConnectorEventOperation.fromValue("DEVICE_DISCOVERY")
operationVersion = "1.0"
statusCode = 200
message = "Sample ConnectorEventMessage"
deviceDiscoveryId = "358275hbk3qr"
devices = listOf<Device>(
Device {
connectorDeviceId = "Mock-Connector-DeviceId-1"
connectorDeviceName = "Sample-User-device-1"
capabilityReport = MatterCapabilityReport {
version = "1.0.0"
nodeId = "1"
endpoints = listOf<MatterCapabilityReportEndpoint>(
MatterCapabilityReportEndpoint {
id = "EP1"
deviceTypes = listOf<String>(
"Refrigerator"
)
clusters = listOf<MatterCapabilityReportCluster>(
MatterCapabilityReportCluster {
id = "0x0201"
revision = 1
attributes = listOf<MatterCapabilityReportAttribute>(
MatterCapabilityReportAttribute {
id = "0x0000"
value = Document("exampleString")
},
MatterCapabilityReportAttribute {
id = "0x0001"
},
MatterCapabilityReportAttribute {
id = "0x0002"
}
)
commands = listOf<String>(
"0x00",
"0x01"
)
events = listOf<String>(
)
}
)
}
)
}
}
)
}
//sampleEnd
}
import aws.sdk.kotlin.services.iotmanagedintegrations.model.ConnectorEventOperation
import aws.sdk.kotlin.services.iotmanagedintegrations.model.Device
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReport
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportAttribute
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportEndpoint
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterEndpoint
import aws.smithy.kotlin.runtime.content.Document
import aws.smithy.kotlin.runtime.content.buildDocument
fun main() {
//sampleStart
// SendConnectorEvent happy path for device command response
val resp = iotManagedIntegrationsClient.sendConnectorEvent {
connectorId = "MockConnectorId"
userId = "MockThirdPartyUserId"
operation = ConnectorEventOperation.fromValue("DEVICE_COMMAND_RESPONSE")
operationVersion = "1.0"
statusCode = 200
message = "Sample ConnectorEventMessage"
traceId = "9b75f3839b6140f=_1"
matterEndpoint = MatterEndpoint {
id = "1"
clusters = listOf<MatterCluster>(
MatterCluster {
id = "0x1003"
attributes = buildDocument {
"0x0000" to Document(
listOf(
Document(73L),
)
)
"0x15570003" to Document("exampleString")
}
commands = mapOf<String, Document?>(
"0x03" to buildDocument {
}
)
}
)
}
}
//sampleEnd
}
import aws.sdk.kotlin.services.iotmanagedintegrations.model.ConnectorEventOperation
import aws.sdk.kotlin.services.iotmanagedintegrations.model.Device
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReport
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportAttribute
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCapabilityReportEndpoint
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterCluster
import aws.sdk.kotlin.services.iotmanagedintegrations.model.MatterEndpoint
import aws.smithy.kotlin.runtime.content.Document
import aws.smithy.kotlin.runtime.content.buildDocument
fun main() {
//sampleStart
// SendConnectorEvent happy path for device event
val resp = iotManagedIntegrationsClient.sendConnectorEvent {
connectorId = "MockConnectorId"
userId = "MockThirdPartyUserId"
operation = ConnectorEventOperation.fromValue("DEVICE_EVENT")
operationVersion = "1.0"
statusCode = 200
message = "Sample ConnectorEventMessage"
traceId = "TraceId-Sample"
matterEndpoint = MatterEndpoint {
id = "1"
clusters = listOf<MatterCluster>(
MatterCluster {
id = "0x1003"
attributes = buildDocument {
"0x0000" to Document(73L)
}
}
)
}
}
//sampleEnd
}