in src/batch.rs [362:386]
fn ddbjson_attributes_to_attrvals(
ddbjson_attributes: &JsonValue,
) -> HashMap<String, AttributeValue> {
let mut built_attributes = HashMap::<String, AttributeValue>::new();
for (attribute_name, body) in ddbjson_attributes
.as_object()
.expect("should be valid JSON object")
.iter()
{
debug!("attribute name is: {}, body is: {:?}", attribute_name, body);
let attr_val: Option<AttributeValue> = ddbjson_val_to_attrval(body);
match attr_val {
Some(v) => {
built_attributes.insert(attribute_name.to_string(), v);
}
None => error!(
"[skip] invalid/unsupported DynamoDB JSON format: {:?}",
body
),
};
}
built_attributes
}