in oss2/xml_utils.py [0:0]
def to_get_select_csv_object_meta(csv_meta_param):
root = ElementTree.Element('CsvMetaRequest')
input_ser = ElementTree.SubElement(root, 'InputSerialization')
csv = ElementTree.SubElement(input_ser, 'CSV')
if (csv_meta_param is None):
return _node_to_string(root)
for key, value in csv_meta_param.items():
if SelectParameters.RecordDelimiter == key:
_add_text_child(csv, SelectParameters.RecordDelimiter, base64.b64encode(str.encode(value)))
elif SelectParameters.FieldDelimiter == key:
_add_text_child(csv, SelectParameters.FieldDelimiter, base64.b64encode(str.encode(value)))
elif SelectParameters.QuoteCharacter == key:
_add_text_child(csv, SelectParameters.QuoteCharacter, base64.b64encode(str.encode(value)))
elif SelectParameters.CompressionType == key:
_add_text_child(input_ser, SelectParameters.CompressionType, base64.b64encode(str.encode(value)))
elif SelectParameters.OverwriteIfExists == key:
_add_text_child(root, SelectParameters.OverwriteIfExists, str(value))
else:
raise SelectOperationClientError("The csv_meta_param contains unsupported key " + key, "")
return _node_to_string(root)