risingwave_connector::parser::unified::debezium

Function extract_bson_field

Source 
pub fn extract_bson_field(
    type_expected: &DataType,
    bson_doc: &Value,
    field: Option<&str>,
) -> AccessResult
Expand description

Extract the field data from the bson document

BSON document is a JSON object with some special fields, such as: long integer: {“$numberLong”: “1630454400000”} date time: {“$date”: {“$numberLong”: “1630454400000”}}

For now, we support only the Canonical format of the date and timestamp.

§NOTE:

  • field indicates the field name in the bson document, if it is None, the bson_doc is the field itself.