sendDataIntegrationEvent
inline suspend fun SupplyChainClient.sendDataIntegrationEvent(crossinline block: SendDataIntegrationEventRequest.Builder.() -> Unit): SendDataIntegrationEventResponse
Send the data payload for the event with real-time data for analysis or monitoring. The real-time data events are stored in an Amazon Web Services service before being processed and stored in data lake.
Samples
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for inboundorder event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.inboundorder")
data = "{\"id\": \"inbound-order-id-test-123\", \"tpartner_id\": \"partner-id-test-123\" }"
eventGroupId = "inboundOrderId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for inboundorderline event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.inboundorderline")
data = "{\"id\": \"inbound-order-line-id-test-123\", \"order_id\": \"order-id-test-123\", \"tpartner_id\": \"partner-id-test-123\", \"product_id\": \"product-id-test-123\", \"quantity_submitted\": \"100.0\" }"
eventGroupId = "inboundOrderLineId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for inboundorderlineschedule event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.inboundorderlineschedule")
data = "{\"id\": \"inbound-order-line-schedule-id-test-123\", \"order_id\": \"order-id-test-123\", \"order_line_id\": \"order-line-id-test-123\", \"product_id\": \"product-id-test-123\"}"
eventGroupId = "inboundOrderLineScheduleId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for forecast event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.forecast")
data = "{\"snapshot_date\": \"1672470400000\", \"product_id\": \"product-id-test-123\", \"site_id\": \"site-id-test-123\", \"region_id\": \"region-id-test-123\", \"product_group_id\": \"product-group-id-test-123\", \"forecast_start_dttm\": \"1672470400000\", \"forecast_end_dttm\": \"1672470400000\" }"
eventGroupId = "forecastId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for inventorylevel event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.inventorylevel")
data = "{\"snapshot_date\": \"1672470400000\", \"site_id\": \"site-id-test-123\", \"product_id\": \"product-id-test-123\", \"on_hand_inventory\": \"100.0\", \"inv_condition\": \"good\", \"lot_number\": \"lot-number-test-123\"}"
eventGroupId = "inventoryLevelId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for outboundorderline event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.outboundorderline")
data = "{\"id\": \"outbound-orderline-id-test-123\", \"cust_order_id\": \"cust-order-id-test-123\", \"product_id\": \"product-id-test-123\" }"
eventGroupId = "outboundOrderLineId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for outboundshipment event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.outboundshipment")
data = "{\"id\": \"outbound-shipment-id-test-123\", \"cust_order_id\": \"cust-order-id-test-123\", \"cust_order_line_id\": \"cust-order-line-id-test-123\", \"product_id\": \"product-id-test-123\" }"
eventGroupId = "outboundShipmentId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for processheader event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.processheader")
data = "{\"process_id\": \"process-id-test-123\" }"
eventGroupId = "processHeaderId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for processoperation event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.processoperation")
data = "{\"process_operation_id\": \"process-operation-id-test-123\", \"process_id\": \"process-id-test-123\" }"
eventGroupId = "processOperationId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for processproduct event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.processproduct")
data = "{\"process_product_id\": \"process-product-id-test-123\", \"process_id\": \"process-id-test-123\" }"
eventGroupId = "processProductId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for reservation event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.reservation")
data = "{\"reservation_id\": \"reservation-id-test-123\", \"reservation_detail_id\": \"reservation-detail-id-test-123\" }"
eventGroupId = "reservationId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for shipment event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.shipment")
data = "{\"id\": \"shipment-id-test-123\", \"supplier_tpartner_id\": \"supplier-tpartner-id-test-123\", \"product_id\": \"product-id-test-123\", \"order_id\": \"order-id-test-123\", \"order_line_id\": \"order-line-id-test-123\", \"package_id\": \"package-id-test-123\" }"
eventGroupId = "shipmentId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for shipmentstop event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.shipmentstop")
data = "{\"shipment_stop_id\": \"shipment-stop-id-test-123\", \"shipment_id\": \"shipment-id-test-123\" }"
eventGroupId = "shipmentStopId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for shipmentstoporder event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.shipmentstoporder")
data = "{\"shipment_stop_order_id\": \"shipment-stop-order-id-test-123\", \"shipment_stop_id\": \"shipment-stop-id-test-123\", \"shipment_id\": \"shipment-id-test-123\" }"
eventGroupId = "shipmentStopOrderId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for supplyplan event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.supplyplan")
data = "{\"supply_plan_id\": \"supply-plan-id-test-123\" }"
eventGroupId = "supplyPlanId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
}
//sampleEnd
}import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetOperationType
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventDatasetTargetConfiguration
import aws.sdk.kotlin.services.supplychain.model.DataIntegrationEventType
import aws.smithy.kotlin.runtime.time.Instant
import aws.smithy.kotlin.runtime.time.fromEpochMilliseconds
fun main() {
//sampleStart
// Successful SendDataIntegrationEvent for dataset event type
val resp = supplyChainClient.sendDataIntegrationEvent {
instanceId = "8928ae12-15e5-4441-825d-ec2184f0a43a"
eventType = DataIntegrationEventType.fromValue("scn.data.dataset")
data = "{\"dataset_id\": \"datset-id-test-123\" }"
eventGroupId = "datasetId"
eventTimestamp = Instant.fromEpochMilliseconds(1515531081123)
datasetTarget = DataIntegrationEventDatasetTargetConfiguration {
datasetIdentifier = "arn:aws:scn:us-west-2:135808960812:instance/8928ae12-15e5-4441-825d-ec2184f0a43a/namespaces/asc/datasets/product"
operationType = DataIntegrationEventDatasetOperationType.fromValue("APPEND")
}
}
//sampleEnd
}