|
|
|
@ -34,7 +34,7 @@ async fn get_client() -> Arc<Client> { |
|
|
|
pub async fn kinesis_put_record(msg: &String) -> Result<(), DeviceError> { |
|
|
|
pub async fn kinesis_put_record(msg: &String) -> Result<(), DeviceError> { |
|
|
|
let blob = msg.as_bytes(); |
|
|
|
let blob = msg.as_bytes(); |
|
|
|
|
|
|
|
|
|
|
|
kinesis_put_bytes(blob) |
|
|
|
kinesis_put_bytes(blob).await |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
pub async fn kinesis_put_bytes(bytes: &[u8]) -> Result<(), DeviceError> { |
|
|
|
pub async fn kinesis_put_bytes(bytes: &[u8]) -> Result<(), DeviceError> { |
|
|
|
|