xml_utils.py 106 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431
  1. # -*- coding: utf-8 -*-
  2. """
  3. oss2.xml_utils
  4. ~~~~~~~~~~~~~~
  5. XML处理相关。
  6. 主要包括两类接口:
  7. - parse_开头的函数:用来解析服务器端返回的XML
  8. - to_开头的函数:用来生成发往服务器端的XML
  9. """
  10. import logging
  11. import xml.etree.ElementTree as ElementTree
  12. import json
  13. from .models import (SimplifiedObjectInfo,
  14. SimplifiedBucketInfo,
  15. PartInfo,
  16. MultipartUploadInfo,
  17. LifecycleRule,
  18. LifecycleExpiration,
  19. CorsRule,
  20. LiveChannelInfoTarget,
  21. LiveChannelInfo,
  22. LiveRecord,
  23. LiveChannelVideoStat,
  24. LiveChannelAudioStat,
  25. Owner,
  26. AccessControlList,
  27. AbortMultipartUpload,
  28. StorageTransition,
  29. Tagging,
  30. TaggingRule,
  31. ServerSideEncryptionRule,
  32. ListObjectVersionsResult,
  33. ObjectVersionInfo,
  34. DeleteMarkerInfo,
  35. BatchDeleteObjectVersionResult,
  36. BucketWebsite,
  37. RoutingRule,
  38. Condition,
  39. ConditionInlcudeHeader,
  40. Redirect,
  41. RedirectMirrorHeaders,
  42. MirrorHeadersSet,
  43. REDIRECT_TYPE_MIRROR,
  44. REDIRECT_TYPE_EXTERNAL,
  45. REDIRECT_TYPE_INTERNAL,
  46. REDIRECT_TYPE_ALICDN,
  47. NoncurrentVersionStorageTransition,
  48. NoncurrentVersionExpiration,
  49. AsyncFetchTaskConfiguration,
  50. InventoryConfiguration,
  51. InventoryFilter,
  52. InventorySchedule,
  53. InventoryDestination,
  54. InventoryBucketDestination,
  55. InventoryServerSideEncryptionKMS,
  56. InventoryServerSideEncryptionOSS,
  57. LocationTransferType,
  58. BucketReplicationProgress,
  59. ReplicationRule,
  60. CnameInfo,
  61. CertificateInfo,
  62. ReplicationRule,
  63. MetaQueryFile,
  64. AggregationsInfo,
  65. OSSTaggingInfo,
  66. OSSUserMetaInfo,
  67. AggregationGroupInfo,
  68. AccessMonitorInfo,
  69. LifecycleFilter,
  70. FilterNot,
  71. FilterNotTag,
  72. BucketStyleInfo,
  73. RegionInfo,
  74. CallbackPolicyInfo,
  75. DataRedundancyTransitionInfo,
  76. ListAccessPointResult,
  77. AccessPointVpcConfiguration,
  78. AccessPointEndpoints,
  79. AccessPointInfo,
  80. PublicAccessBlockConfiguration,
  81. ResourcePoolInfo,
  82. ResourcePoolBucketInfo,
  83. RequesterQoSInfo,
  84. QoSConfiguration)
  85. from .select_params import (SelectJsonTypes, SelectParameters)
  86. from .compat import urlunquote, to_unicode, to_string
  87. from .utils import iso8601_to_unixtime, date_to_iso8601, iso8601_to_date
  88. from . import utils
  89. import base64
  90. from .exceptions import SelectOperationClientError
  91. logger = logging.getLogger(__name__)
  92. def _find_tag(parent, path):
  93. child = parent.find(path)
  94. if child is None:
  95. raise RuntimeError("parse xml: " + path + " could not be found under " + parent.tag)
  96. if child.text is None:
  97. return ''
  98. return to_string(child.text)
  99. def _find_tag_with_default(parent, path, default_value):
  100. child = parent.find(path)
  101. if child is None:
  102. return default_value
  103. if child.text is None:
  104. return ''
  105. return to_string(child.text)
  106. def _find_bool(parent, path):
  107. text = _find_tag(parent, path)
  108. if text == 'true':
  109. return True
  110. elif text == 'false':
  111. return False
  112. else:
  113. raise RuntimeError("parse xml: value of " + path + " is not a boolean under " + parent.tag)
  114. def _find_int(parent, path):
  115. return int(_find_tag(parent, path))
  116. def _find_object(parent, path, url_encoded):
  117. name = _find_tag(parent, path)
  118. if url_encoded:
  119. return urlunquote(name)
  120. else:
  121. return name
  122. def _find_all_tags(parent, tag):
  123. return [to_string(node.text) or '' for node in parent.findall(tag)]
  124. def _is_url_encoding(root):
  125. node = root.find('EncodingType')
  126. if node is not None and to_string(node.text) == 'url':
  127. return True
  128. else:
  129. return False
  130. def _node_to_string(root):
  131. return ElementTree.tostring(root, encoding='utf-8')
  132. def _add_node_list(parent, tag, entries):
  133. for e in entries:
  134. _add_text_child(parent, tag, e)
  135. def _add_text_child(parent, tag, text):
  136. ElementTree.SubElement(parent, tag).text = to_unicode(text)
  137. def _add_node_child(parent, tag):
  138. return ElementTree.SubElement(parent, tag)
  139. def parse_list_objects(result, body):
  140. root = ElementTree.fromstring(body)
  141. url_encoded = _is_url_encoding(root)
  142. result.is_truncated = _find_bool(root, 'IsTruncated')
  143. if result.is_truncated:
  144. result.next_marker = _find_object(root, 'NextMarker', url_encoded)
  145. for contents_node in root.findall('Contents'):
  146. owner = None
  147. if contents_node.find("Owner") is not None:
  148. owner = Owner(_find_tag(contents_node, 'Owner/DisplayName'), _find_tag(contents_node, 'Owner/ID'))
  149. result.object_list.append(SimplifiedObjectInfo(
  150. _find_object(contents_node, 'Key', url_encoded),
  151. iso8601_to_unixtime(_find_tag(contents_node, 'LastModified')),
  152. _find_tag(contents_node, 'ETag').strip('"'),
  153. _find_tag(contents_node, 'Type'),
  154. int(_find_tag(contents_node, 'Size')),
  155. _find_tag(contents_node, 'StorageClass'),
  156. owner,
  157. _find_tag_with_default(contents_node, 'RestoreInfo', None)
  158. ))
  159. for prefix_node in root.findall('CommonPrefixes'):
  160. result.prefix_list.append(_find_object(prefix_node, 'Prefix', url_encoded))
  161. return result
  162. def parse_list_objects_v2(result, body):
  163. root = ElementTree.fromstring(body)
  164. url_encoded = _is_url_encoding(root)
  165. result.is_truncated = _find_bool(root, 'IsTruncated')
  166. if result.is_truncated:
  167. result.next_continuation_token = _find_object(root, 'NextContinuationToken', url_encoded)
  168. for contents_node in root.findall('Contents'):
  169. owner = None
  170. if contents_node.find("Owner") is not None:
  171. owner = Owner(_find_tag(contents_node, 'Owner/DisplayName'), _find_tag(contents_node, 'Owner/ID'))
  172. result.object_list.append(SimplifiedObjectInfo(
  173. _find_object(contents_node, 'Key', url_encoded),
  174. iso8601_to_unixtime(_find_tag(contents_node, 'LastModified')),
  175. _find_tag(contents_node, 'ETag').strip('"'),
  176. _find_tag(contents_node, 'Type'),
  177. int(_find_tag(contents_node, 'Size')),
  178. _find_tag(contents_node, 'StorageClass'),
  179. owner,
  180. _find_tag_with_default(contents_node, 'RestoreInfo', None)
  181. ))
  182. for prefix_node in root.findall('CommonPrefixes'):
  183. result.prefix_list.append(_find_object(prefix_node, 'Prefix', url_encoded))
  184. return result
  185. def parse_list_buckets(result, body):
  186. root = ElementTree.fromstring(body)
  187. if root.find('IsTruncated') is None:
  188. result.is_truncated = False
  189. else:
  190. result.is_truncated = _find_bool(root, 'IsTruncated')
  191. if result.is_truncated:
  192. result.next_marker = _find_tag(root, 'NextMarker')
  193. if root.find('Owner') is not None:
  194. result.owner = Owner(_find_tag_with_default(root, 'Owner/DisplayName', None), _find_tag_with_default(root, 'Owner/ID', None))
  195. for bucket_node in root.findall('Buckets/Bucket'):
  196. result.buckets.append(SimplifiedBucketInfo(
  197. _find_tag(bucket_node, 'Name'),
  198. _find_tag(bucket_node, 'Location'),
  199. iso8601_to_unixtime(_find_tag(bucket_node, 'CreationDate')),
  200. _find_tag(bucket_node, 'ExtranetEndpoint'),
  201. _find_tag(bucket_node, 'IntranetEndpoint'),
  202. _find_tag(bucket_node, 'StorageClass'),
  203. _find_tag_with_default(bucket_node, 'Region', None),
  204. _find_tag_with_default(bucket_node, 'ResourceGroupId', None),
  205. ))
  206. return result
  207. def parse_init_multipart_upload(result, body):
  208. root = ElementTree.fromstring(body)
  209. result.upload_id = _find_tag(root, 'UploadId')
  210. return result
  211. def parse_list_multipart_uploads(result, body):
  212. root = ElementTree.fromstring(body)
  213. url_encoded = _is_url_encoding(root)
  214. result.is_truncated = _find_bool(root, 'IsTruncated')
  215. result.next_key_marker = _find_object(root, 'NextKeyMarker', url_encoded)
  216. result.next_upload_id_marker = _find_tag(root, 'NextUploadIdMarker')
  217. for upload_node in root.findall('Upload'):
  218. result.upload_list.append(MultipartUploadInfo(
  219. _find_object(upload_node, 'Key', url_encoded),
  220. _find_tag(upload_node, 'UploadId'),
  221. iso8601_to_unixtime(_find_tag(upload_node, 'Initiated'))
  222. ))
  223. for prefix_node in root.findall('CommonPrefixes'):
  224. result.prefix_list.append(_find_object(prefix_node, 'Prefix', url_encoded))
  225. return result
  226. def parse_list_parts(result, body):
  227. root = ElementTree.fromstring(body)
  228. result.is_truncated = _find_bool(root, 'IsTruncated')
  229. result.next_marker = _find_tag(root, 'NextPartNumberMarker')
  230. for part_node in root.findall('Part'):
  231. result.parts.append(PartInfo(
  232. _find_int(part_node, 'PartNumber'),
  233. _find_tag(part_node, 'ETag').strip('"'),
  234. size=_find_int(part_node, 'Size'),
  235. last_modified=iso8601_to_unixtime(_find_tag(part_node, 'LastModified'))
  236. ))
  237. return result
  238. def parse_batch_delete_objects(result, body):
  239. if not body:
  240. return result
  241. root = ElementTree.fromstring(body)
  242. url_encoded = _is_url_encoding(root)
  243. for deleted_node in root.findall('Deleted'):
  244. key = _find_object(deleted_node, 'Key', url_encoded)
  245. result.deleted_keys.append(key)
  246. versionid_node = deleted_node.find('VersionId')
  247. versionid = None
  248. if versionid_node is not None:
  249. versionid = _find_tag(deleted_node, 'VersionId')
  250. delete_marker_node = deleted_node.find('DeleteMarker')
  251. delete_marker = False
  252. if delete_marker_node is not None:
  253. delete_marker = _find_bool(deleted_node, 'DeleteMarker')
  254. marker_versionid_node = deleted_node.find('DeleteMarkerVersionId')
  255. delete_marker_versionid = ''
  256. if marker_versionid_node is not None:
  257. delete_marker_versionid = _find_tag(deleted_node, 'DeleteMarkerVersionId')
  258. result.delete_versions.append(BatchDeleteObjectVersionResult(key, versionid, delete_marker, delete_marker_versionid))
  259. return result
  260. def parse_get_bucket_acl(result, body):
  261. root = ElementTree.fromstring(body)
  262. result.acl = _find_tag(root, 'AccessControlList/Grant')
  263. return result
  264. def parse_get_object_acl(result, body):
  265. root = ElementTree.fromstring(body)
  266. result.acl = _find_tag(root, 'AccessControlList/Grant')
  267. return result
  268. def parse_get_bucket_location(result, body):
  269. result.location = to_string(ElementTree.fromstring(body).text)
  270. return result
  271. def parse_get_bucket_logging(result, body):
  272. root = ElementTree.fromstring(body)
  273. if root.find('LoggingEnabled/TargetBucket') is not None:
  274. result.target_bucket = _find_tag(root, 'LoggingEnabled/TargetBucket')
  275. if root.find('LoggingEnabled/TargetPrefix') is not None:
  276. result.target_prefix = _find_tag(root, 'LoggingEnabled/TargetPrefix')
  277. return result
  278. def parse_get_bucket_stat(result, body):
  279. root = ElementTree.fromstring(body)
  280. result.storage_size_in_bytes = _find_int(root, 'Storage')
  281. result.object_count = _find_int(root, 'ObjectCount')
  282. result.multi_part_upload_count = int(_find_tag_with_default(root, 'MultipartUploadCount', 0))
  283. if root.find('LiveChannelCount') is not None:
  284. result.live_channel_count = int(_find_tag(root, 'LiveChannelCount'))
  285. if root.find('LastModifiedTime') is not None:
  286. result.last_modified_time = int(_find_tag(root, 'LastModifiedTime'))
  287. if root.find('StandardStorage') is not None:
  288. result.standard_storage = int(_find_tag(root, 'StandardStorage'))
  289. if root.find('StandardObjectCount') is not None:
  290. result.standard_object_count = int(_find_tag(root, 'StandardObjectCount'))
  291. if root.find('InfrequentAccessStorage') is not None:
  292. result.infrequent_access_storage = int(_find_tag(root, 'InfrequentAccessStorage'))
  293. if root.find('InfrequentAccessRealStorage') is not None:
  294. result.infrequent_access_real_storage = int(_find_tag(root, 'InfrequentAccessRealStorage'))
  295. if root.find('InfrequentAccessObjectCount') is not None:
  296. result.infrequent_access_object_count = int(_find_tag(root, 'InfrequentAccessObjectCount'))
  297. if root.find('ArchiveStorage') is not None:
  298. result.archive_storage = int(_find_tag(root, 'ArchiveStorage'))
  299. if root.find('ArchiveRealStorage') is not None:
  300. result.archive_real_storage = int(_find_tag(root, 'ArchiveRealStorage'))
  301. if root.find('ArchiveObjectCount') is not None:
  302. result.archive_object_count = int(_find_tag(root, 'ArchiveObjectCount'))
  303. if root.find('ColdArchiveStorage') is not None:
  304. result.cold_archive_storage = int(_find_tag(root, 'ColdArchiveStorage'))
  305. if root.find('ColdArchiveRealStorage') is not None:
  306. result.cold_archive_real_storage = int(_find_tag(root, 'ColdArchiveRealStorage'))
  307. if root.find('ColdArchiveObjectCount') is not None:
  308. result.cold_archive_object_count = int(_find_tag(root, 'ColdArchiveObjectCount'))
  309. if root.find('MultipartPartCount') is not None:
  310. result.multipart_part_count = int(_find_tag(root, 'MultipartPartCount'))
  311. if root.find('DeleteMarkerCount') is not None:
  312. result.delete_marker_count = int(_find_tag(root, 'DeleteMarkerCount'))
  313. if root.find('DeepColdArchiveStorage') is not None:
  314. result.deep_cold_archive_storage = int(_find_tag(root, 'DeepColdArchiveStorage'))
  315. if root.find('DeepColdArchiveRealStorage') is not None:
  316. result.deep_cold_archive_real_storage = int(_find_tag(root, 'DeepColdArchiveRealStorage'))
  317. if root.find('DeepColdArchiveObjectCount') is not None:
  318. result.deep_cold_archive_object_count = int(_find_tag(root, 'DeepColdArchiveObjectCount'))
  319. return result
  320. def parse_get_bucket_info(result, body):
  321. root = ElementTree.fromstring(body)
  322. result.name = _find_tag(root, 'Bucket/Name')
  323. result.creation_date = _find_tag(root, 'Bucket/CreationDate')
  324. result.storage_class = _find_tag(root, 'Bucket/StorageClass')
  325. result.extranet_endpoint = _find_tag(root, 'Bucket/ExtranetEndpoint')
  326. result.intranet_endpoint = _find_tag(root, 'Bucket/IntranetEndpoint')
  327. result.location = _find_tag(root, 'Bucket/Location')
  328. result.owner = Owner(_find_tag(root, 'Bucket/Owner/DisplayName'), _find_tag(root, 'Bucket/Owner/ID'))
  329. result.acl = AccessControlList(_find_tag(root, 'Bucket/AccessControlList/Grant'))
  330. result.comment = _find_tag_with_default(root, 'Bucket/Comment', None)
  331. result.versioning_status = _find_tag_with_default(root, 'Bucket/Versioning', None)
  332. result.data_redundancy_type = _find_tag_with_default(root, 'Bucket/DataRedundancyType', None)
  333. result.access_monitor = _find_tag_with_default(root, 'Bucket/AccessMonitor', None)
  334. result.transfer_acceleration = _find_tag_with_default(root, 'Bucket/TransferAcceleration', None)
  335. result.cross_region_replication = _find_tag_with_default(root, 'Bucket/CrossRegionReplication', None)
  336. result.resource_group_id = _find_tag_with_default(root, 'Bucket/ResourceGroupId', None)
  337. server_side_encryption = root.find("Bucket/ServerSideEncryptionRule")
  338. if server_side_encryption is None:
  339. result.bucket_encryption_rule = None
  340. else:
  341. result.bucket_encryption_rule = _parse_bucket_encryption_info(server_side_encryption)
  342. return result
  343. def _parse_bucket_encryption_info(node):
  344. rule = ServerSideEncryptionRule()
  345. rule.sse_algorithm = _find_tag(node,"SSEAlgorithm")
  346. if rule.sse_algorithm == "None":
  347. rule.kms_master_keyid = None
  348. rule.sse_algorithm = None
  349. return rule
  350. kmsnode = node.find("KMSMasterKeyID")
  351. if kmsnode is None or kmsnode.text is None:
  352. rule.kms_master_keyid = None
  353. else:
  354. rule.kms_master_keyid = to_string(kmsnode.text)
  355. kms_data_encryption_node = node.find("KMSDataEncryption")
  356. if kms_data_encryption_node is None or kms_data_encryption_node.text is None:
  357. rule.kms_data_encryption = None
  358. else:
  359. rule.kms_data_encryption = to_string(kms_data_encryption_node.text)
  360. return rule
  361. def parse_get_bucket_referer(result, body):
  362. root = ElementTree.fromstring(body)
  363. result.allow_empty_referer = _find_bool(root, 'AllowEmptyReferer')
  364. result.referers = _find_all_tags(root, 'RefererList/Referer')
  365. if root.find("AllowTruncateQueryString") is not None:
  366. result.allow_truncate_query_string = _find_bool(root, 'AllowTruncateQueryString')
  367. if root.find("RefererBlacklist/Referer") is not None:
  368. result.black_referers = _find_all_tags(root, 'RefererBlacklist/Referer')
  369. return result
  370. def parse_condition_include_header(include_header_node):
  371. key = _find_tag(include_header_node, 'Key')
  372. equals = _find_tag(include_header_node, 'Equals')
  373. include_header = ConditionInlcudeHeader(key, equals)
  374. return include_header
  375. def parse_routing_rule_condition(condition_node):
  376. if condition_node.find('KeyPrefixEquals') is not None:
  377. key_prefix_equals = _find_tag(condition_node, 'KeyPrefixEquals')
  378. if condition_node.find('HttpErrorCodeReturnedEquals') is not None:
  379. http_err_code_return_equals = _find_int(condition_node, 'HttpErrorCodeReturnedEquals');
  380. include_header_list = []
  381. if condition_node.find('IncludeHeader') is not None:
  382. for include_header_node in condition_node.findall('IncludeHeader'):
  383. include_header = parse_condition_include_header(include_header_node)
  384. include_header_list.append(include_header)
  385. condition = Condition(key_prefix_equals, http_err_code_return_equals, include_header_list)
  386. return condition
  387. def parse_mirror_headers(mirror_headers_node):
  388. if mirror_headers_node is None:
  389. return None
  390. pass_all = None
  391. if mirror_headers_node.find('PassAll') is not None:
  392. pass_all = _find_bool(mirror_headers_node, 'PassAll')
  393. pass_list = _find_all_tags(mirror_headers_node, 'Pass')
  394. remove_list = _find_all_tags(mirror_headers_node, 'Remove')
  395. set_list = []
  396. for set_node in mirror_headers_node.findall('Set'):
  397. key = _find_tag(set_node, 'Key')
  398. value = _find_tag(set_node, 'Value')
  399. mirror_headers_set = MirrorHeadersSet(key, value)
  400. set_list.append(mirror_headers_set)
  401. redirect_mirror_headers = RedirectMirrorHeaders(pass_all, pass_list, remove_list, set_list)
  402. return redirect_mirror_headers
  403. def parse_routing_rule_redirect(redirect_node):
  404. redirect_type = None
  405. pass_query_string = None
  406. replace_key_with = None
  407. replace_key_prefix_with = None
  408. proto = None
  409. host_name = None
  410. http_redirect_code = None
  411. mirror_url = None
  412. mirror_url_slave = None
  413. mirror_url_probe = None
  414. mirror_pass_query_string = None
  415. mirror_check_md5 = None
  416. mirror_follow_redirect = None
  417. mirror_headers = None
  418. # common args
  419. redirect_type = _find_tag(redirect_node, 'RedirectType')
  420. if redirect_node.find('PassQueryString') is not None:
  421. pass_query_string = _find_bool(redirect_node, 'PassQueryString')
  422. # External, AliCDN
  423. if redirect_type in [REDIRECT_TYPE_EXTERNAL, REDIRECT_TYPE_ALICDN]:
  424. if redirect_node.find('Protocol') is not None:
  425. proto = _find_tag(redirect_node, 'Protocol')
  426. if redirect_node.find('HostName') is not None:
  427. host_name = _find_tag(redirect_node, 'HostName')
  428. if redirect_node.find('HttpRedirectCode') is not None:
  429. http_redirect_code = _find_int(redirect_node, 'HttpRedirectCode')
  430. # External, AliCDN, Internal
  431. if redirect_type in [REDIRECT_TYPE_EXTERNAL, REDIRECT_TYPE_ALICDN, REDIRECT_TYPE_INTERNAL]:
  432. if redirect_node.find('ReplaceKeyWith') is not None:
  433. replace_key_with = _find_tag(redirect_node, 'ReplaceKeyWith')
  434. if redirect_node.find('ReplaceKeyPrefixWith') is not None:
  435. replace_key_prefix_with = _find_tag(redirect_node, 'ReplaceKeyPrefixWith')
  436. # Mirror
  437. elif redirect_type == REDIRECT_TYPE_MIRROR:
  438. if redirect_node.find('MirrorURL') is not None:
  439. mirror_url = _find_tag(redirect_node, 'MirrorURL')
  440. if redirect_node.find('MirrorURLSlave') is not None:
  441. mirror_url_slave = _find_tag(redirect_node, 'MirrorURLSlave')
  442. if redirect_node.find('MirrorURLProbe') is not None:
  443. mirror_url_probe = _find_tag(redirect_node, 'MirrorURLProbe')
  444. if redirect_node.find('MirrorPassQueryString') is not None:
  445. mirror_pass_query_string = _find_bool(redirect_node, 'MirrorPassQueryString')
  446. if redirect_node.find('MirrorCheckMd5') is not None:
  447. mirror_check_md5 = _find_bool(redirect_node, 'MirrorCheckMd5')
  448. if redirect_node.find('MirrorFollowRedirect') is not None:
  449. mirror_follow_redirect = _find_bool(redirect_node, 'MirrorFollowRedirect')
  450. mirror_headers = parse_mirror_headers(redirect_node.find('MirrorHeaders'))
  451. redirect = Redirect(redirect_type=redirect_type, proto=proto, host_name=host_name, replace_key_with=replace_key_with,
  452. replace_key_prefix_with=replace_key_prefix_with, http_redirect_code=http_redirect_code,
  453. pass_query_string=pass_query_string, mirror_url=mirror_url,mirror_url_slave=mirror_url_slave,
  454. mirror_url_probe=mirror_url_probe, mirror_pass_query_string=mirror_pass_query_string,
  455. mirror_follow_redirect=mirror_follow_redirect, mirror_check_md5=mirror_check_md5,
  456. mirror_headers=mirror_headers)
  457. return redirect
  458. def parse_get_bucket_website(result, body):
  459. root = ElementTree.fromstring(body)
  460. result.index_file = _find_tag_with_default(root, 'IndexDocument/Suffix', None)
  461. result.error_file = _find_tag_with_default(root, 'ErrorDocument/Key', None)
  462. if root.find('RoutingRules') is None:
  463. return result
  464. routing_rules_node = root.find('RoutingRules')
  465. for rule_node in routing_rules_node.findall('RoutingRule'):
  466. rule_num = _find_int(rule_node, 'RuleNumber')
  467. condition = parse_routing_rule_condition(rule_node.find('Condition'))
  468. redirect = parse_routing_rule_redirect(rule_node.find('Redirect'))
  469. rule = RoutingRule(rule_num, condition, redirect);
  470. result.rules.append(rule)
  471. return result
  472. def parse_create_live_channel(result, body):
  473. root = ElementTree.fromstring(body)
  474. result.play_url = _find_tag(root, 'PlayUrls/Url')
  475. result.publish_url = _find_tag(root, 'PublishUrls/Url')
  476. return result
  477. def parse_get_live_channel(result, body):
  478. root = ElementTree.fromstring(body)
  479. result.status = _find_tag(root, 'Status')
  480. result.description = _find_tag(root, 'Description')
  481. target = LiveChannelInfoTarget()
  482. target.type = _find_tag(root, 'Target/Type')
  483. target.frag_duration = _find_tag(root, 'Target/FragDuration')
  484. target.frag_count = _find_tag(root, 'Target/FragCount')
  485. target.playlist_name = _find_tag(root, 'Target/PlaylistName')
  486. result.target = target
  487. return result
  488. def parse_list_live_channel(result, body):
  489. root = ElementTree.fromstring(body)
  490. result.prefix = _find_tag(root, 'Prefix')
  491. result.marker = _find_tag(root, 'Marker')
  492. result.max_keys = _find_int(root, 'MaxKeys')
  493. result.is_truncated = _find_bool(root, 'IsTruncated')
  494. if result.is_truncated:
  495. result.next_marker = _find_tag(root, 'NextMarker')
  496. channels = root.findall('LiveChannel')
  497. for channel in channels:
  498. tmp = LiveChannelInfo()
  499. tmp.name = _find_tag(channel, 'Name')
  500. tmp.description = _find_tag(channel, 'Description')
  501. tmp.status = _find_tag(channel, 'Status')
  502. tmp.last_modified = iso8601_to_unixtime(_find_tag(channel, 'LastModified'))
  503. tmp.play_url = _find_tag(channel, 'PlayUrls/Url')
  504. tmp.publish_url = _find_tag(channel, 'PublishUrls/Url')
  505. result.channels.append(tmp)
  506. return result
  507. def parse_stat_video(video_node, video):
  508. video.width = _find_int(video_node, 'Width')
  509. video.height = _find_int(video_node, 'Height')
  510. video.frame_rate = _find_int(video_node, 'FrameRate')
  511. video.bandwidth = _find_int(video_node, 'Bandwidth')
  512. video.codec = _find_tag(video_node, 'Codec')
  513. def parse_stat_audio(audio_node, audio):
  514. audio.bandwidth = _find_int(audio_node, 'Bandwidth')
  515. audio.sample_rate = _find_int(audio_node, 'SampleRate')
  516. audio.codec = _find_tag(audio_node, 'Codec')
  517. def parse_live_channel_stat(result, body):
  518. root = ElementTree.fromstring(body)
  519. result.status = _find_tag(root, 'Status')
  520. if root.find('RemoteAddr') is not None:
  521. result.remote_addr = _find_tag(root, 'RemoteAddr')
  522. if root.find('ConnectedTime') is not None:
  523. result.connected_time = iso8601_to_unixtime(_find_tag(root, 'ConnectedTime'))
  524. video_node = root.find('Video')
  525. audio_node = root.find('Audio')
  526. if video_node is not None:
  527. result.video = LiveChannelVideoStat()
  528. parse_stat_video(video_node, result.video)
  529. if audio_node is not None:
  530. result.audio = LiveChannelAudioStat()
  531. parse_stat_audio(audio_node, result.audio)
  532. return result
  533. def parse_live_channel_history(result, body):
  534. root = ElementTree.fromstring(body)
  535. records = root.findall('LiveRecord')
  536. for record in records:
  537. tmp = LiveRecord()
  538. tmp.start_time = iso8601_to_unixtime(_find_tag(record, 'StartTime'))
  539. tmp.end_time = iso8601_to_unixtime(_find_tag(record, 'EndTime'))
  540. tmp.remote_addr = _find_tag(record, 'RemoteAddr')
  541. result.records.append(tmp)
  542. return result
  543. def parse_lifecycle_expiration(expiration_node):
  544. if expiration_node is None:
  545. return None
  546. expiration = LifecycleExpiration()
  547. if expiration_node.find('Days') is not None:
  548. expiration.days = _find_int(expiration_node, 'Days')
  549. elif expiration_node.find('Date') is not None:
  550. expiration.date = iso8601_to_date(_find_tag(expiration_node, 'Date'))
  551. elif expiration_node.find('CreatedBeforeDate') is not None:
  552. expiration.created_before_date = iso8601_to_date(_find_tag(expiration_node, 'CreatedBeforeDate'))
  553. elif expiration_node.find('ExpiredObjectDeleteMarker') is not None:
  554. expiration.expired_detete_marker = _find_bool(expiration_node, 'ExpiredObjectDeleteMarker')
  555. return expiration
  556. def parse_lifecycle_abort_multipart_upload(abort_multipart_upload_node):
  557. if abort_multipart_upload_node is None:
  558. return None
  559. abort_multipart_upload = AbortMultipartUpload()
  560. if abort_multipart_upload_node.find('Days') is not None:
  561. abort_multipart_upload.days = _find_int(abort_multipart_upload_node, 'Days')
  562. elif abort_multipart_upload_node.find('CreatedBeforeDate') is not None:
  563. abort_multipart_upload.created_before_date = iso8601_to_date(_find_tag(abort_multipart_upload_node,
  564. 'CreatedBeforeDate'))
  565. return abort_multipart_upload
  566. def parse_lifecycle_storage_transitions(storage_transition_nodes):
  567. storage_transitions = []
  568. for storage_transition_node in storage_transition_nodes:
  569. storage_class = _find_tag(storage_transition_node, 'StorageClass')
  570. storage_transition = StorageTransition(storage_class=storage_class)
  571. if storage_transition_node.find('Days') is not None:
  572. storage_transition.days = _find_int(storage_transition_node, 'Days')
  573. elif storage_transition_node.find('CreatedBeforeDate') is not None:
  574. storage_transition.created_before_date = iso8601_to_date(_find_tag(storage_transition_node,
  575. 'CreatedBeforeDate'))
  576. if storage_transition_node.find('IsAccessTime') is not None:
  577. storage_transition.is_access_time = _find_bool(storage_transition_node, 'IsAccessTime')
  578. if storage_transition_node.find('ReturnToStdWhenVisit') is not None:
  579. storage_transition.return_to_std_when_visit = _find_bool(storage_transition_node, 'ReturnToStdWhenVisit')
  580. if storage_transition_node.find('AllowSmallFile') is not None:
  581. storage_transition.allow_small_file = _find_bool(storage_transition_node, 'AllowSmallFile')
  582. storage_transitions.append(storage_transition)
  583. return storage_transitions
  584. def parse_lifecycle_object_taggings(lifecycle_tagging_nodes):
  585. if lifecycle_tagging_nodes is None or \
  586. len(lifecycle_tagging_nodes) == 0:
  587. return None
  588. tagging_rule = TaggingRule()
  589. for tag_node in lifecycle_tagging_nodes:
  590. key = _find_tag(tag_node, 'Key')
  591. value = _find_tag(tag_node, 'Value')
  592. tagging_rule.add(key, value)
  593. return Tagging(tagging_rule)
  594. def parse_lifecycle_version_expiration(version_expiration_node):
  595. if version_expiration_node is None:
  596. return None
  597. noncurrent_days = _find_int(version_expiration_node, 'NoncurrentDays')
  598. expiration = NoncurrentVersionExpiration(noncurrent_days)
  599. return expiration
  600. def parse_lifecycle_verison_storage_transitions(version_storage_transition_nodes):
  601. version_storage_transitions = []
  602. for transition_node in version_storage_transition_nodes:
  603. storage_class = _find_tag(transition_node, 'StorageClass')
  604. non_crurrent_days = _find_int(transition_node, 'NoncurrentDays')
  605. version_storage_transition = NoncurrentVersionStorageTransition(non_crurrent_days, storage_class)
  606. if transition_node.find('IsAccessTime') is not None:
  607. version_storage_transition.is_access_time = _find_bool(transition_node, 'IsAccessTime')
  608. if transition_node.find('ReturnToStdWhenVisit') is not None:
  609. version_storage_transition.return_to_std_when_visit = _find_bool(transition_node, 'ReturnToStdWhenVisit')
  610. if transition_node.find('AllowSmallFile') is not None:
  611. version_storage_transition.allow_small_file = _find_bool(transition_node, 'AllowSmallFile')
  612. version_storage_transitions.append(version_storage_transition)
  613. return version_storage_transitions
  614. def parse_get_bucket_lifecycle(result, body):
  615. root = ElementTree.fromstring(body)
  616. url_encoded = _is_url_encoding(root)
  617. for rule_node in root.findall('Rule'):
  618. expiration = parse_lifecycle_expiration(rule_node.find('Expiration'))
  619. abort_multipart_upload = parse_lifecycle_abort_multipart_upload(rule_node.find('AbortMultipartUpload'))
  620. storage_transitions = parse_lifecycle_storage_transitions(rule_node.findall('Transition'))
  621. tagging = parse_lifecycle_object_taggings(rule_node.findall('Tag'))
  622. noncurrent_version_expiration = parse_lifecycle_version_expiration(rule_node.find('NoncurrentVersionExpiration'))
  623. noncurrent_version_sotrage_transitions = parse_lifecycle_verison_storage_transitions(rule_node.findall('NoncurrentVersionTransition'))
  624. lifecycle_filter = parse_lifecycle_filter(rule_node.find('Filter'))
  625. rule = LifecycleRule(
  626. _find_tag(rule_node, 'ID'),
  627. _find_tag(rule_node, 'Prefix'),
  628. status=_find_tag(rule_node, 'Status'),
  629. expiration=expiration,
  630. abort_multipart_upload=abort_multipart_upload,
  631. storage_transitions=storage_transitions,
  632. tagging=tagging,
  633. noncurrent_version_expiration = noncurrent_version_expiration,
  634. noncurrent_version_sotrage_transitions = noncurrent_version_sotrage_transitions,
  635. atime_base=int(_find_tag_with_default(rule_node, 'AtimeBase', 0)),
  636. filter=lifecycle_filter
  637. )
  638. result.rules.append(rule)
  639. return result
  640. def parse_get_bucket_cors(result, body):
  641. root = ElementTree.fromstring(body)
  642. for rule_node in root.findall('CORSRule'):
  643. rule = CorsRule()
  644. rule.allowed_origins = _find_all_tags(rule_node, 'AllowedOrigin')
  645. rule.allowed_methods = _find_all_tags(rule_node, 'AllowedMethod')
  646. rule.allowed_headers = _find_all_tags(rule_node, 'AllowedHeader')
  647. rule.expose_headers = _find_all_tags(rule_node, 'ExposeHeader')
  648. max_age_node = rule_node.find('MaxAgeSeconds')
  649. if max_age_node is not None:
  650. rule.max_age_seconds = int(max_age_node.text)
  651. result.rules.append(rule)
  652. return result
  653. def to_complete_upload_request(parts):
  654. root = ElementTree.Element('CompleteMultipartUpload')
  655. for p in parts:
  656. part_node = ElementTree.SubElement(root, "Part")
  657. _add_text_child(part_node, 'PartNumber', str(p.part_number))
  658. _add_text_child(part_node, 'ETag', '"{0}"'.format(p.etag))
  659. return _node_to_string(root)
  660. def to_batch_delete_objects_request(keys, quiet):
  661. root_node = ElementTree.Element('Delete')
  662. _add_text_child(root_node, 'Quiet', str(quiet).lower())
  663. for key in keys:
  664. object_node = ElementTree.SubElement(root_node, 'Object')
  665. _add_text_child(object_node, 'Key', key)
  666. return _node_to_string(root_node)
  667. def to_batch_delete_objects_version_request(objectVersions, quiet):
  668. root_node = ElementTree.Element('Delete')
  669. _add_text_child(root_node, 'Quiet', str(quiet).lower())
  670. objectVersionList = objectVersions.object_version_list
  671. for ver in objectVersionList:
  672. object_node = ElementTree.SubElement(root_node, 'Object')
  673. _add_text_child(object_node, 'Key', ver.key)
  674. if ver.versionid != '':
  675. _add_text_child(object_node, 'VersionId', ver.versionid)
  676. return _node_to_string(root_node)
  677. def to_put_bucket_config(bucket_config):
  678. root = ElementTree.Element('CreateBucketConfiguration')
  679. _add_text_child(root, 'StorageClass', bucket_config.storage_class)
  680. if bucket_config.data_redundancy_type is not None:
  681. _add_text_child(root, 'DataRedundancyType', bucket_config.data_redundancy_type)
  682. return _node_to_string(root)
  683. def to_put_bucket_logging(bucket_logging):
  684. root = ElementTree.Element('BucketLoggingStatus')
  685. if bucket_logging.target_bucket:
  686. logging_node = ElementTree.SubElement(root, 'LoggingEnabled')
  687. _add_text_child(logging_node, 'TargetBucket', bucket_logging.target_bucket)
  688. _add_text_child(logging_node, 'TargetPrefix', bucket_logging.target_prefix)
  689. return _node_to_string(root)
  690. def to_put_bucket_referer(bucket_referer):
  691. root = ElementTree.Element('RefererConfiguration')
  692. _add_text_child(root, 'AllowEmptyReferer', str(bucket_referer.allow_empty_referer).lower())
  693. list_node = ElementTree.SubElement(root, 'RefererList')
  694. for r in bucket_referer.referers:
  695. _add_text_child(list_node, 'Referer', r)
  696. if bucket_referer.allow_truncate_query_string is not None:
  697. _add_text_child(root, 'AllowTruncateQueryString', str(bucket_referer.allow_truncate_query_string).lower())
  698. if bucket_referer.black_referers:
  699. black_referer_node = ElementTree.SubElement(root, 'RefererBlacklist')
  700. for r in bucket_referer.black_referers:
  701. _add_text_child(black_referer_node, 'Referer', r)
  702. return _node_to_string(root)
  703. def to_put_bucket_website(bucket_website):
  704. root = ElementTree.Element('WebsiteConfiguration')
  705. index_node = ElementTree.SubElement(root, 'IndexDocument')
  706. _add_text_child(index_node, 'Suffix', bucket_website.index_file)
  707. error_node = ElementTree.SubElement(root, 'ErrorDocument')
  708. _add_text_child(error_node, 'Key', bucket_website.error_file)
  709. if len(bucket_website.rules) == 0:
  710. return _node_to_string(root)
  711. rules_node = ElementTree.SubElement(root, "RoutingRules")
  712. for rule in bucket_website.rules:
  713. rule_node = ElementTree.SubElement(rules_node, 'RoutingRule')
  714. _add_text_child(rule_node, 'RuleNumber', str(rule.rule_num))
  715. condition_node = ElementTree.SubElement(rule_node, 'Condition')
  716. if rule.condition.key_prefix_equals is not None:
  717. _add_text_child(condition_node, 'KeyPrefixEquals', rule.condition.key_prefix_equals)
  718. if rule.condition.http_err_code_return_equals is not None:
  719. _add_text_child(condition_node, 'HttpErrorCodeReturnedEquals',
  720. str(rule.condition.http_err_code_return_equals))
  721. for header in rule.condition.include_header_list:
  722. include_header_node = ElementTree.SubElement(condition_node, 'IncludeHeader')
  723. _add_text_child(include_header_node, 'Key', header.key)
  724. _add_text_child(include_header_node, 'Equals', header.equals)
  725. if rule.redirect is not None:
  726. redirect_node = ElementTree.SubElement(rule_node, 'Redirect')
  727. # common
  728. _add_text_child(redirect_node, 'RedirectType', rule.redirect.redirect_type)
  729. if rule.redirect.pass_query_string is not None:
  730. _add_text_child(redirect_node, 'PassQueryString', str(rule.redirect.pass_query_string))
  731. # External, AliCDN
  732. if rule.redirect.redirect_type in [REDIRECT_TYPE_EXTERNAL, REDIRECT_TYPE_ALICDN]:
  733. if rule.redirect.proto is not None:
  734. _add_text_child(redirect_node, 'Protocol', rule.redirect.proto)
  735. if rule.redirect.host_name is not None:
  736. _add_text_child(redirect_node, 'HostName', rule.redirect.host_name)
  737. if rule.redirect.http_redirect_code is not None:
  738. _add_text_child(redirect_node, 'HttpRedirectCode', str(rule.redirect.http_redirect_code))
  739. # External, AliCDN, Internal
  740. if rule.redirect.redirect_type in [REDIRECT_TYPE_EXTERNAL, REDIRECT_TYPE_ALICDN, REDIRECT_TYPE_INTERNAL]:
  741. if rule.redirect.replace_key_with is not None:
  742. _add_text_child(redirect_node, 'ReplaceKeyWith', rule.redirect.replace_key_with)
  743. if rule.redirect.replace_key_prefix_with is not None:
  744. _add_text_child(redirect_node, 'ReplaceKeyPrefixWith', rule.redirect.replace_key_prefix_with)
  745. # Mirror
  746. elif rule.redirect.redirect_type == REDIRECT_TYPE_MIRROR:
  747. if rule.redirect.mirror_url is not None:
  748. _add_text_child(redirect_node, 'MirrorURL', rule.redirect.mirror_url)
  749. if rule.redirect.mirror_url_slave is not None:
  750. _add_text_child(redirect_node, 'MirrorURLSlave', rule.redirect.mirror_url_slave)
  751. if rule.redirect.mirror_url_probe is not None:
  752. _add_text_child(redirect_node, 'MirrorURLProbe', rule.redirect.mirror_url_probe)
  753. if rule.redirect.mirror_pass_query_string is not None:
  754. _add_text_child(redirect_node, 'MirrorPassQueryString', str(rule.redirect.mirror_pass_query_string))
  755. if rule.redirect.mirror_follow_redirect is not None:
  756. _add_text_child(redirect_node, 'MirrorFollowRedirect', str(rule.redirect.mirror_follow_redirect))
  757. if rule.redirect.mirror_check_md5 is not None:
  758. _add_text_child(redirect_node, 'MirrorCheckMd5', str(rule.redirect.mirror_check_md5))
  759. if rule.redirect.mirror_headers is not None:
  760. mirror_headers_node = ElementTree.SubElement(redirect_node, 'MirrorHeaders')
  761. if rule.redirect.mirror_headers.pass_all is not None:
  762. _add_text_child(mirror_headers_node, 'PassAll', str(rule.redirect.mirror_headers.pass_all))
  763. for pass_param in rule.redirect.mirror_headers.pass_list:
  764. _add_text_child(mirror_headers_node, 'Pass', pass_param)
  765. for remove_param in rule.redirect.mirror_headers.remove_list:
  766. _add_text_child(mirror_headers_node, 'Remove', remove_param)
  767. for set_param in rule.redirect.mirror_headers.set_list:
  768. set_node = ElementTree.SubElement(mirror_headers_node, 'Set')
  769. _add_text_child(set_node, 'Key', set_param.key)
  770. _add_text_child(set_node, 'Value', set_param.value)
  771. return _node_to_string(root)
  772. def to_put_bucket_lifecycle(bucket_lifecycle):
  773. root = ElementTree.Element('LifecycleConfiguration')
  774. for rule in bucket_lifecycle.rules:
  775. rule_node = ElementTree.SubElement(root, 'Rule')
  776. _add_text_child(rule_node, 'ID', rule.id)
  777. _add_text_child(rule_node, 'Prefix', rule.prefix)
  778. _add_text_child(rule_node, 'Status', rule.status)
  779. expiration = rule.expiration
  780. if expiration:
  781. expiration_node = ElementTree.SubElement(rule_node, 'Expiration')
  782. if expiration.days is not None:
  783. _add_text_child(expiration_node, 'Days', str(expiration.days))
  784. elif expiration.date is not None:
  785. _add_text_child(expiration_node, 'Date', date_to_iso8601(expiration.date))
  786. elif expiration.created_before_date is not None:
  787. _add_text_child(expiration_node, 'CreatedBeforeDate', date_to_iso8601(expiration.created_before_date))
  788. elif expiration.expired_detete_marker is not None:
  789. _add_text_child(expiration_node, 'ExpiredObjectDeleteMarker', str(expiration.expired_detete_marker))
  790. abort_multipart_upload = rule.abort_multipart_upload
  791. if abort_multipart_upload:
  792. abort_multipart_upload_node = ElementTree.SubElement(rule_node, 'AbortMultipartUpload')
  793. if abort_multipart_upload.days is not None:
  794. _add_text_child(abort_multipart_upload_node, 'Days', str(abort_multipart_upload.days))
  795. elif abort_multipart_upload.created_before_date is not None:
  796. _add_text_child(abort_multipart_upload_node, 'CreatedBeforeDate',
  797. date_to_iso8601(abort_multipart_upload.created_before_date))
  798. storage_transitions = rule.storage_transitions
  799. if storage_transitions:
  800. for storage_transition in storage_transitions:
  801. storage_transition_node = ElementTree.SubElement(rule_node, 'Transition')
  802. _add_text_child(storage_transition_node, 'StorageClass', str(storage_transition.storage_class))
  803. if storage_transition.is_access_time is not None:
  804. _add_text_child(storage_transition_node, 'IsAccessTime', str(storage_transition.is_access_time).lower())
  805. if storage_transition.return_to_std_when_visit is not None:
  806. _add_text_child(storage_transition_node, 'ReturnToStdWhenVisit', str(storage_transition.return_to_std_when_visit).lower())
  807. if storage_transition.allow_small_file is not None:
  808. _add_text_child(storage_transition_node, 'AllowSmallFile', str(storage_transition.allow_small_file).lower())
  809. if storage_transition.days is not None:
  810. _add_text_child(storage_transition_node, 'Days', str(storage_transition.days))
  811. elif storage_transition.created_before_date is not None:
  812. _add_text_child(storage_transition_node, 'CreatedBeforeDate',
  813. date_to_iso8601(storage_transition.created_before_date))
  814. tagging = rule.tagging
  815. if tagging:
  816. tagging_rule = tagging.tag_set.tagging_rule
  817. for key in tagging.tag_set.tagging_rule:
  818. tag_node = ElementTree.SubElement(rule_node, 'Tag')
  819. _add_text_child(tag_node, 'Key', key)
  820. _add_text_child(tag_node, 'Value', tagging_rule[key])
  821. noncurrent_version_expiration = rule.noncurrent_version_expiration
  822. if noncurrent_version_expiration is not None:
  823. version_expiration_node = ElementTree.SubElement(rule_node, 'NoncurrentVersionExpiration')
  824. _add_text_child(version_expiration_node, 'NoncurrentDays', str(noncurrent_version_expiration.noncurrent_days))
  825. noncurrent_version_sotrage_transitions = rule.noncurrent_version_sotrage_transitions
  826. if noncurrent_version_sotrage_transitions is not None:
  827. for noncurrent_version_sotrage_transition in noncurrent_version_sotrage_transitions:
  828. version_transition_node = ElementTree.SubElement(rule_node, 'NoncurrentVersionTransition')
  829. _add_text_child(version_transition_node, 'NoncurrentDays', str(noncurrent_version_sotrage_transition.noncurrent_days))
  830. _add_text_child(version_transition_node, 'StorageClass', str(noncurrent_version_sotrage_transition.storage_class))
  831. if noncurrent_version_sotrage_transition.is_access_time is not None:
  832. _add_text_child(version_transition_node, 'IsAccessTime', str(noncurrent_version_sotrage_transition.is_access_time).lower())
  833. if noncurrent_version_sotrage_transition.return_to_std_when_visit is not None:
  834. _add_text_child(version_transition_node, 'ReturnToStdWhenVisit', str(noncurrent_version_sotrage_transition.return_to_std_when_visit).lower())
  835. if noncurrent_version_sotrage_transition.allow_small_file is not None:
  836. _add_text_child(version_transition_node, 'AllowSmallFile', str(noncurrent_version_sotrage_transition.allow_small_file).lower())
  837. if rule.filter:
  838. filter_node = ElementTree.SubElement(rule_node, "Filter")
  839. if rule.filter.object_size_greater_than:
  840. _add_text_child(filter_node, 'ObjectSizeGreaterThan', str(rule.filter.object_size_greater_than))
  841. if rule.filter.object_size_less_than:
  842. _add_text_child(filter_node, 'ObjectSizeLessThan', str(rule.filter.object_size_less_than))
  843. if rule.filter.filter_not:
  844. for not_arg in rule.filter.filter_not:
  845. not_node = ElementTree.SubElement(filter_node, 'Not')
  846. _add_text_child(not_node, 'Prefix', not_arg.prefix)
  847. if not_arg.tag:
  848. tag_node = ElementTree.SubElement(not_node, 'Tag')
  849. _add_text_child(tag_node, 'Key', not_arg.tag.key)
  850. _add_text_child(tag_node, 'Value', not_arg.tag.value)
  851. return _node_to_string(root)
  852. def to_put_bucket_cors(bucket_cors):
  853. root = ElementTree.Element('CORSConfiguration')
  854. for rule in bucket_cors.rules:
  855. rule_node = ElementTree.SubElement(root, 'CORSRule')
  856. _add_node_list(rule_node, 'AllowedOrigin', rule.allowed_origins)
  857. _add_node_list(rule_node, 'AllowedMethod', rule.allowed_methods)
  858. _add_node_list(rule_node, 'AllowedHeader', rule.allowed_headers)
  859. _add_node_list(rule_node, 'ExposeHeader', rule.expose_headers)
  860. if rule.max_age_seconds is not None:
  861. _add_text_child(rule_node, 'MaxAgeSeconds', str(rule.max_age_seconds))
  862. return _node_to_string(root)
  863. def to_create_live_channel(live_channel):
  864. root = ElementTree.Element('LiveChannelConfiguration')
  865. _add_text_child(root, 'Description', live_channel.description)
  866. _add_text_child(root, 'Status', live_channel.status)
  867. target_node = _add_node_child(root, 'Target')
  868. _add_text_child(target_node, 'Type', live_channel.target.type)
  869. _add_text_child(target_node, 'FragDuration', str(live_channel.target.frag_duration))
  870. _add_text_child(target_node, 'FragCount', str(live_channel.target.frag_count))
  871. _add_text_child(target_node, 'PlaylistName', str(live_channel.target.playlist_name))
  872. return _node_to_string(root)
  873. def to_select_object(sql, select_params):
  874. if (select_params is not None and 'Json_Type' in select_params):
  875. return to_select_json_object(sql, select_params)
  876. else:
  877. return to_select_csv_object(sql, select_params)
  878. def to_select_csv_object(sql, select_params):
  879. root = ElementTree.Element('SelectRequest')
  880. _add_text_child(root, 'Expression', base64.b64encode(str.encode(sql)))
  881. input_ser = ElementTree.SubElement(root, 'InputSerialization')
  882. output_ser = ElementTree.SubElement(root, 'OutputSerialization')
  883. csv = ElementTree.SubElement(input_ser, 'CSV')
  884. out_csv = ElementTree.SubElement(output_ser, 'CSV')
  885. options = ElementTree.SubElement(root, 'Options')
  886. if (select_params is None):
  887. return _node_to_string(root)
  888. for key, value in select_params.items():
  889. if SelectParameters.CsvHeaderInfo == key:
  890. _add_text_child(csv, 'FileHeaderInfo', value)
  891. elif SelectParameters.CommentCharacter == key:
  892. _add_text_child(csv, SelectParameters.CommentCharacter, base64.b64encode(str.encode(value)))
  893. elif SelectParameters.RecordDelimiter == key:
  894. _add_text_child(csv, SelectParameters.RecordDelimiter, base64.b64encode(str.encode(value)))
  895. elif SelectParameters.OutputRecordDelimiter == key:
  896. _add_text_child(out_csv, SelectParameters.RecordDelimiter, base64.b64encode(str.encode(value)))
  897. elif SelectParameters.FieldDelimiter == key:
  898. _add_text_child(csv, SelectParameters.FieldDelimiter, base64.b64encode(str.encode(value)))
  899. elif SelectParameters.OutputFieldDelimiter == key:
  900. _add_text_child(out_csv, SelectParameters.FieldDelimiter, base64.b64encode(str.encode(value)))
  901. elif SelectParameters.QuoteCharacter == key:
  902. _add_text_child(csv, SelectParameters.QuoteCharacter, base64.b64encode(str.encode(value)))
  903. elif SelectParameters.SplitRange == key:
  904. _add_text_child(csv, 'Range', utils._make_split_range_string(value))
  905. elif SelectParameters.LineRange == key:
  906. _add_text_child(csv, 'Range', utils._make_line_range_string(value))
  907. elif SelectParameters.CompressionType == key:
  908. _add_text_child(input_ser, SelectParameters.CompressionType, str(value))
  909. elif SelectParameters.KeepAllColumns == key:
  910. _add_text_child(output_ser, SelectParameters.KeepAllColumns, str(value))
  911. elif SelectParameters.OutputRawData == key:
  912. _add_text_child(output_ser, SelectParameters.OutputRawData, str(value))
  913. elif SelectParameters.EnablePayloadCrc == key:
  914. _add_text_child(output_ser, SelectParameters.EnablePayloadCrc, str(value))
  915. elif SelectParameters.OutputHeader == key:
  916. _add_text_child(output_ser, SelectParameters.OutputHeader, str(value))
  917. elif SelectParameters.SkipPartialDataRecord == key:
  918. _add_text_child(options, SelectParameters.SkipPartialDataRecord, str(value))
  919. elif SelectParameters.MaxSkippedRecordsAllowed == key:
  920. _add_text_child(options, SelectParameters.MaxSkippedRecordsAllowed, str(value))
  921. elif SelectParameters.AllowQuotedRecordDelimiter == key:
  922. _add_text_child(csv, SelectParameters.AllowQuotedRecordDelimiter, str(value))
  923. else:
  924. raise SelectOperationClientError("The select_params contains unsupported key " + key, "")
  925. return _node_to_string(root)
  926. def to_select_json_object(sql, select_params):
  927. root = ElementTree.Element('SelectRequest')
  928. _add_text_child(root, 'Expression', base64.b64encode(str.encode(sql)))
  929. input_ser = ElementTree.SubElement(root, 'InputSerialization')
  930. output_ser = ElementTree.SubElement(root, 'OutputSerialization')
  931. json = ElementTree.SubElement(input_ser, 'JSON')
  932. out_json = ElementTree.SubElement(output_ser, 'JSON')
  933. options = ElementTree.SubElement(root, 'Options')
  934. is_doc = select_params[SelectParameters.Json_Type] == SelectJsonTypes.DOCUMENT
  935. _add_text_child(json, 'Type', select_params[SelectParameters.Json_Type])
  936. for key, value in select_params.items():
  937. if SelectParameters.SplitRange == key and is_doc == False:
  938. _add_text_child(json, 'Range', utils._make_split_range_string(value))
  939. elif SelectParameters.LineRange == key and is_doc == False:
  940. _add_text_child(json, 'Range', utils._make_line_range_string(value))
  941. elif SelectParameters.CompressionType == key:
  942. _add_text_child(input_ser, SelectParameters.CompressionType, value)
  943. elif SelectParameters.OutputRawData == key:
  944. _add_text_child(output_ser, SelectParameters.OutputRawData, str(value))
  945. elif SelectParameters.EnablePayloadCrc == key:
  946. _add_text_child(output_ser, SelectParameters.EnablePayloadCrc, str(value))
  947. elif SelectParameters.OutputRecordDelimiter == key:
  948. _add_text_child(out_json, SelectParameters.RecordDelimiter, base64.b64encode(str.encode(value)))
  949. elif SelectParameters.SkipPartialDataRecord == key:
  950. _add_text_child(options, SelectParameters.SkipPartialDataRecord, str(value))
  951. elif SelectParameters.MaxSkippedRecordsAllowed == key:
  952. _add_text_child(options, SelectParameters.MaxSkippedRecordsAllowed, str(value))
  953. elif SelectParameters.ParseJsonNumberAsString == key:
  954. _add_text_child(json, SelectParameters.ParseJsonNumberAsString, str(value))
  955. else:
  956. if key != SelectParameters.Json_Type:
  957. raise SelectOperationClientError("The select_params contains unsupported key " + key, "")
  958. return _node_to_string(root)
  959. def to_get_select_object_meta(meta_param):
  960. if meta_param is not None and SelectParameters.Json_Type in meta_param:
  961. if meta_param[SelectParameters.Json_Type] != SelectJsonTypes.LINES:
  962. raise SelectOperationClientError("Json_Type can only be 'LINES' for creating meta", "")
  963. else:
  964. return to_get_select_json_object_meta(meta_param)
  965. else:
  966. return to_get_select_csv_object_meta(meta_param)
  967. def to_get_select_csv_object_meta(csv_meta_param):
  968. root = ElementTree.Element('CsvMetaRequest')
  969. input_ser = ElementTree.SubElement(root, 'InputSerialization')
  970. csv = ElementTree.SubElement(input_ser, 'CSV')
  971. if (csv_meta_param is None):
  972. return _node_to_string(root)
  973. for key, value in csv_meta_param.items():
  974. if SelectParameters.RecordDelimiter == key:
  975. _add_text_child(csv, SelectParameters.RecordDelimiter, base64.b64encode(str.encode(value)))
  976. elif SelectParameters.FieldDelimiter == key:
  977. _add_text_child(csv, SelectParameters.FieldDelimiter, base64.b64encode(str.encode(value)))
  978. elif SelectParameters.QuoteCharacter == key:
  979. _add_text_child(csv, SelectParameters.QuoteCharacter, base64.b64encode(str.encode(value)))
  980. elif SelectParameters.CompressionType == key:
  981. _add_text_child(input_ser, SelectParameters.CompressionType, base64.b64encode(str.encode(value)))
  982. elif SelectParameters.OverwriteIfExists == key:
  983. _add_text_child(root, SelectParameters.OverwriteIfExists, str(value))
  984. else:
  985. raise SelectOperationClientError("The csv_meta_param contains unsupported key " + key, "")
  986. return _node_to_string(root)
  987. def to_get_select_json_object_meta(json_meta_param):
  988. root = ElementTree.Element('JsonMetaRequest')
  989. input_ser = ElementTree.SubElement(root, 'InputSerialization')
  990. json = ElementTree.SubElement(input_ser, 'JSON')
  991. _add_text_child(json, 'Type', json_meta_param[SelectParameters.Json_Type]) # Json_Type是必须的
  992. for key, value in json_meta_param.items():
  993. if SelectParameters.OverwriteIfExists == key:
  994. _add_text_child(root, SelectParameters.OverwriteIfExists, str(value))
  995. elif SelectParameters.CompressionType == key:
  996. _add_text_child(input_ser, SelectParameters.CompressionType, base64.b64encode(str.encode(value)))
  997. else:
  998. if SelectParameters.Json_Type != key:
  999. raise SelectOperationClientError("The json_meta_param contains unsupported key " + key, "")
  1000. return _node_to_string(root)
  1001. def to_put_tagging(object_tagging):
  1002. root = ElementTree.Element("Tagging")
  1003. tag_set = ElementTree.SubElement(root, "TagSet")
  1004. for item in object_tagging.tag_set.tagging_rule:
  1005. tag_xml = ElementTree.SubElement(tag_set, "Tag")
  1006. _add_text_child(tag_xml, 'Key', item)
  1007. _add_text_child(tag_xml, 'Value', object_tagging.tag_set.tagging_rule[item])
  1008. return _node_to_string(root)
  1009. def parse_get_tagging(result, body):
  1010. root = ElementTree.fromstring(body)
  1011. url_encoded = _is_url_encoding(root)
  1012. tagset_node = root.find('TagSet')
  1013. if tagset_node is None:
  1014. return result
  1015. tagging_rules = TaggingRule()
  1016. for tag_node in tagset_node.findall('Tag'):
  1017. key = _find_object(tag_node, 'Key', url_encoded)
  1018. value = _find_object(tag_node, 'Value', url_encoded)
  1019. tagging_rules.add(key, value)
  1020. result.tag_set = tagging_rules
  1021. return result
  1022. def to_put_bucket_encryption(rule):
  1023. root = ElementTree.Element("ServerSideEncryptionRule")
  1024. apply_node = ElementTree.SubElement(root, "ApplyServerSideEncryptionByDefault")
  1025. _add_text_child(apply_node, "SSEAlgorithm", rule.sse_algorithm)
  1026. if rule.kms_master_keyid:
  1027. _add_text_child(apply_node, "KMSMasterKeyID", rule.kms_master_keyid)
  1028. if rule.kms_data_encryption:
  1029. _add_text_child(apply_node, "KMSDataEncryption", rule.kms_data_encryption)
  1030. return _node_to_string(root)
  1031. def parse_get_bucket_encryption(result, body):
  1032. root = ElementTree.fromstring(body)
  1033. apply_node = root.find('ApplyServerSideEncryptionByDefault')
  1034. result.sse_algorithm = _find_tag(apply_node, "SSEAlgorithm")
  1035. kmsnode = apply_node.find('KMSMasterKeyID')
  1036. if kmsnode is None or kmsnode.text is None:
  1037. result.kms_master_keyid = None
  1038. else:
  1039. result.kms_master_keyid = to_string(kmsnode.text)
  1040. kms_data_encryption_node = apply_node.find('KMSDataEncryption')
  1041. if kms_data_encryption_node is None or kms_data_encryption_node.text is None:
  1042. result.kms_data_encryption = None
  1043. else:
  1044. result.kms_data_encryption = to_string(kms_data_encryption_node.text)
  1045. return result
  1046. def parse_list_object_versions(result, body):
  1047. root = ElementTree.fromstring(body)
  1048. url_encoded = _is_url_encoding(root)
  1049. result.is_truncated = _find_bool(root, 'IsTruncated')
  1050. if result.is_truncated:
  1051. result.next_key_marker = _find_object(root, 'NextKeyMarker', url_encoded)
  1052. result.next_versionid_marker = _find_object(root, "NextVersionIdMarker", url_encoded)
  1053. result.name = _find_tag(root, "Name")
  1054. result.prefix = _find_object(root, "Prefix", url_encoded)
  1055. result.key_marker = _find_object(root, "KeyMarker", url_encoded)
  1056. result.versionid_marker = _find_object(root, "VersionIdMarker", url_encoded)
  1057. result.max_keys = _find_int(root, "MaxKeys")
  1058. result.delimiter = _find_object(root, "Delimiter", url_encoded)
  1059. for delete_marker in root.findall("DeleteMarker"):
  1060. deleteInfo = DeleteMarkerInfo()
  1061. deleteInfo.key = _find_object(delete_marker, "Key", url_encoded)
  1062. deleteInfo.versionid = _find_tag(delete_marker, "VersionId")
  1063. deleteInfo.is_latest = _find_bool(delete_marker, "IsLatest")
  1064. deleteInfo.last_modified = iso8601_to_unixtime(_find_tag(delete_marker, "LastModified"))
  1065. deleteInfo.owner.id = _find_tag(delete_marker, "Owner/ID")
  1066. deleteInfo.owner.display_name = _find_tag(delete_marker, "Owner/DisplayName")
  1067. result.delete_marker.append(deleteInfo)
  1068. for version in root.findall("Version"):
  1069. versionInfo = ObjectVersionInfo()
  1070. versionInfo.key = _find_object(version, "Key", url_encoded)
  1071. versionInfo.versionid = _find_tag(version, "VersionId")
  1072. versionInfo.is_latest = _find_bool(version, "IsLatest")
  1073. versionInfo.last_modified = iso8601_to_unixtime(_find_tag(version, "LastModified"))
  1074. versionInfo.owner.id = _find_tag(version, "Owner/ID")
  1075. versionInfo.owner.display_name = _find_tag(version, "Owner/DisplayName")
  1076. versionInfo.type = _find_tag(version, "Type")
  1077. versionInfo.storage_class = _find_tag(version, "StorageClass")
  1078. versionInfo.size = _find_int(version, "Size")
  1079. versionInfo.etag = _find_tag(version, "ETag").strip('"')
  1080. versionInfo.restore_info = _find_tag_with_default(version, 'RestoreInfo', None)
  1081. result.versions.append(versionInfo)
  1082. for common_prefix in root.findall("CommonPrefixes"):
  1083. result.common_prefix.append(_find_object(common_prefix, "Prefix", url_encoded))
  1084. return result
  1085. def to_put_bucket_versioning(bucket_version_config):
  1086. root = ElementTree.Element('VersioningConfiguration')
  1087. _add_text_child(root, 'Status', str(bucket_version_config.status))
  1088. return _node_to_string(root)
  1089. def parse_get_bucket_versioning(result, body):
  1090. root = ElementTree.fromstring(body)
  1091. status_node = root.find("Status")
  1092. if status_node is None:
  1093. result.status = None
  1094. else:
  1095. result.status = _find_tag(root, "Status")
  1096. return result
  1097. def to_put_bucket_request_payment(payer):
  1098. root = ElementTree.Element('RequestPaymentConfiguration')
  1099. _add_text_child(root, 'Payer', payer)
  1100. return _node_to_string(root)
  1101. def parse_get_bucket_request_payment(result, body):
  1102. root = ElementTree.fromstring(body)
  1103. result.payer = _find_tag(root, 'Payer')
  1104. return result
  1105. def to_put_qos_info(qos_info):
  1106. root = ElementTree.Element("QoSConfiguration")
  1107. if qos_info.total_upload_bw is not None:
  1108. _add_text_child(root, "TotalUploadBandwidth", str(qos_info.total_upload_bw))
  1109. if qos_info.intranet_upload_bw is not None:
  1110. _add_text_child(root, "IntranetUploadBandwidth", str(qos_info.intranet_upload_bw))
  1111. if qos_info.extranet_upload_bw is not None:
  1112. _add_text_child(root, "ExtranetUploadBandwidth", str(qos_info.extranet_upload_bw))
  1113. if qos_info.total_download_bw is not None:
  1114. _add_text_child(root, "TotalDownloadBandwidth", str(qos_info.total_download_bw))
  1115. if qos_info.intranet_download_bw is not None:
  1116. _add_text_child(root, "IntranetDownloadBandwidth", str(qos_info.intranet_download_bw))
  1117. if qos_info.extranet_download_bw is not None:
  1118. _add_text_child(root, "ExtranetDownloadBandwidth", str(qos_info.extranet_download_bw))
  1119. if qos_info.total_qps is not None:
  1120. _add_text_child(root, "TotalQps", str(qos_info.total_qps))
  1121. if qos_info.intranet_qps is not None:
  1122. _add_text_child(root, "IntranetQps", str(qos_info.intranet_qps))
  1123. if qos_info.extranet_qps is not None:
  1124. _add_text_child(root, "ExtranetQps", str(qos_info.extranet_qps))
  1125. return _node_to_string(root)
  1126. def parse_get_qos_info(result, body):
  1127. """解析UserQosInfo 或者BucketQosInfo
  1128. :UserQosInfo包含成员region,其他成员同BucketQosInfo
  1129. """
  1130. root = ElementTree.fromstring(body)
  1131. if hasattr(result, 'region'):
  1132. result.region = _find_tag(root, 'Region')
  1133. result.total_upload_bw = _find_int(root, 'TotalUploadBandwidth')
  1134. result.intranet_upload_bw = _find_int(root, 'IntranetUploadBandwidth')
  1135. result.extranet_upload_bw = _find_int(root, 'ExtranetUploadBandwidth')
  1136. result.total_download_bw = _find_int(root, 'TotalDownloadBandwidth')
  1137. result.intranet_download_bw = _find_int(root, 'IntranetDownloadBandwidth')
  1138. result.extranet_download_bw = _find_int(root, 'ExtranetDownloadBandwidth')
  1139. result.total_qps = _find_int(root, 'TotalQps')
  1140. result.intranet_qps = _find_int(root, 'IntranetQps')
  1141. result.extranet_qps = _find_int(root, 'ExtranetQps')
  1142. return result
  1143. def parse_get_bucket_user_qos(result, body):
  1144. root = ElementTree.fromstring(body)
  1145. result.storage_capacity = _find_int(root, 'StorageCapacity')
  1146. return result
  1147. def to_put_bucket_user_qos(user_qos):
  1148. root = ElementTree.Element('BucketUserQos')
  1149. _add_text_child(root, 'StorageCapacity', str(user_qos.storage_capacity))
  1150. return _node_to_string(root)
  1151. def to_put_async_fetch_task(task_config):
  1152. root = ElementTree.Element('AsyncFetchTaskConfiguration')
  1153. _add_text_child(root, 'Url', task_config.url)
  1154. _add_text_child(root, 'Object', task_config.object_name)
  1155. if task_config.host is not None:
  1156. _add_text_child(root, 'Host', task_config.host)
  1157. if task_config.content_md5 is not None:
  1158. _add_text_child(root, 'ContentMD5', task_config.content_md5)
  1159. if task_config.callback is not None:
  1160. _add_text_child(root, 'Callback', task_config.callback)
  1161. if task_config.ignore_same_key is not None:
  1162. _add_text_child(root, 'IgnoreSameKey', str(task_config.ignore_same_key).lower())
  1163. if task_config.callback_when_failed is not None:
  1164. _add_text_child(root, 'CallbackWhenFailed', str(task_config.callback_when_failed).lower())
  1165. return _node_to_string(root)
  1166. def parse_put_async_fetch_task_result(result, body):
  1167. root = ElementTree.fromstring(body)
  1168. result.task_id = _find_tag(root, 'TaskId')
  1169. return result
  1170. def _parse_async_fetch_task_configuration(task_info_node):
  1171. url = _find_tag(task_info_node, 'Url')
  1172. object_name = _find_tag(task_info_node, 'Object')
  1173. host = _find_tag(task_info_node, 'Host')
  1174. content_md5 = _find_tag(task_info_node, 'ContentMD5')
  1175. callback = _find_tag(task_info_node, 'Callback')
  1176. ignore_same_key = _find_bool(task_info_node, 'IgnoreSameKey')
  1177. return AsyncFetchTaskConfiguration(url, object_name, host, content_md5, callback, ignore_same_key)
  1178. def parse_get_async_fetch_task_result(result, body):
  1179. root = ElementTree.fromstring(body)
  1180. result.task_id = _find_tag(root, 'TaskId')
  1181. result.task_state = _find_tag(root, 'State')
  1182. result.error_msg = _find_tag(root, 'ErrorMsg')
  1183. result.task_config = _parse_async_fetch_task_configuration(root.find('TaskInfo'))
  1184. return result
  1185. def to_put_inventory_configuration(inventory_config):
  1186. root = ElementTree.Element("InventoryConfiguration")
  1187. _add_text_child(root, "Id", inventory_config.inventory_id)
  1188. if inventory_config.is_enabled is not None:
  1189. _add_text_child(root, "IsEnabled", str(inventory_config.is_enabled))
  1190. if inventory_config.included_object_versions is not None:
  1191. _add_text_child(root, "IncludedObjectVersions", inventory_config.included_object_versions)
  1192. if inventory_config.inventory_filter is not None:
  1193. filter_node = ElementTree.SubElement(root, 'Filter')
  1194. if inventory_config.inventory_filter.prefix is not None:
  1195. _add_text_child(filter_node, "Prefix", inventory_config.inventory_filter.prefix)
  1196. if inventory_config.inventory_filter.last_modify_begin_time_stamp is not None:
  1197. _add_text_child(filter_node, "LastModifyBeginTimeStamp", str(inventory_config.inventory_filter.last_modify_begin_time_stamp))
  1198. if inventory_config.inventory_filter.last_modify_end_time_stamp is not None:
  1199. _add_text_child(filter_node, "LastModifyEndTimeStamp", str(inventory_config.inventory_filter.last_modify_end_time_stamp))
  1200. if inventory_config.inventory_filter.lower_size_bound is not None:
  1201. _add_text_child(filter_node, "LowerSizeBound", str(inventory_config.inventory_filter.lower_size_bound))
  1202. if inventory_config.inventory_filter.upper_size_bound is not None:
  1203. _add_text_child(filter_node, "UpperSizeBound", str(inventory_config.inventory_filter.upper_size_bound))
  1204. if inventory_config.inventory_filter.storage_class is not None:
  1205. _add_text_child(filter_node, "StorageClass", inventory_config.inventory_filter.storage_class)
  1206. if inventory_config.inventory_schedule is not None and inventory_config.inventory_schedule.frequency is not None:
  1207. schedule_node = ElementTree.SubElement(root, 'Schedule')
  1208. _add_text_child(schedule_node, "Frequency", inventory_config.inventory_schedule.frequency)
  1209. if inventory_config.optional_fields is not None:
  1210. fields_node = ElementTree.SubElement(root, 'OptionalFields')
  1211. for field in inventory_config.optional_fields:
  1212. _add_text_child(fields_node, "Field", field)
  1213. if inventory_config.inventory_destination is not None and inventory_config.inventory_destination.bucket_destination is not None:
  1214. destin_node = ElementTree.SubElement(root, 'Destination')
  1215. bucket_destin_node = ElementTree.SubElement(destin_node, 'OSSBucketDestination')
  1216. bucket_destin = inventory_config.inventory_destination.bucket_destination
  1217. if bucket_destin.account_id is not None:
  1218. _add_text_child(bucket_destin_node, "AccountId", str(bucket_destin.account_id))
  1219. if bucket_destin.role_arn is not None:
  1220. _add_text_child(bucket_destin_node, "RoleArn", bucket_destin.role_arn)
  1221. if bucket_destin.bucket is not None:
  1222. _add_text_child(bucket_destin_node, "Bucket", "acs:oss:::" + bucket_destin.bucket)
  1223. if bucket_destin.inventory_format is not None:
  1224. _add_text_child(bucket_destin_node, "Format", bucket_destin.inventory_format)
  1225. if bucket_destin.prefix is not None:
  1226. _add_text_child(bucket_destin_node, "Prefix", bucket_destin.prefix)
  1227. if bucket_destin.sse_kms_encryption is not None:
  1228. encryption_node = ElementTree.SubElement(bucket_destin_node, 'Encryption')
  1229. sse_kms_node = ElementTree.SubElement(encryption_node, 'SSE-KMS')
  1230. _add_text_child(sse_kms_node, "KeyId", bucket_destin.sse_kms_encryption.key_id)
  1231. elif bucket_destin.sse_oss_encryption is not None:
  1232. encryption_node = ElementTree.SubElement(bucket_destin_node, 'Encryption')
  1233. _add_node_child(encryption_node, 'SSE-OSS')
  1234. return _node_to_string(root)
  1235. def get_Inventory_configuration_from_element(elem):
  1236. root = elem
  1237. result = InventoryConfiguration()
  1238. result.inventory_id = _find_tag(root, 'Id')
  1239. result.is_enabled = _find_bool(root, 'IsEnabled')
  1240. result.included_object_versions = _find_tag(root, 'IncludedObjectVersions')
  1241. if root.find("Filter") is not None:
  1242. prefix = None
  1243. last_modify_begin_time_stamp = None
  1244. last_modify_end_time_stamp = None
  1245. lower_size_bound = None
  1246. upper_size_bound = None
  1247. storage_class = None
  1248. if root.find("Filter/Prefix") is not None:
  1249. prefix = _find_tag(root, 'Filter/Prefix')
  1250. if root.find("Filter/LastModifyBeginTimeStamp") is not None:
  1251. last_modify_begin_time_stamp = _find_tag_with_default(root, 'Filter/LastModifyBeginTimeStamp', None)
  1252. if root.find("Filter/LastModifyEndTimeStamp") is not None:
  1253. last_modify_end_time_stamp = _find_tag_with_default(root, 'Filter/LastModifyEndTimeStamp', None)
  1254. if root.find("Filter/LowerSizeBound") is not None:
  1255. lower_size_bound = _find_tag_with_default(root, 'Filter/LowerSizeBound', None)
  1256. if root.find("Filter/UpperSizeBound") is not None:
  1257. upper_size_bound = _find_tag_with_default(root, 'Filter/UpperSizeBound', None)
  1258. if root.find("Filter/StorageClass") is not None:
  1259. storage_class = _find_tag_with_default(root, 'Filter/StorageClass', None)
  1260. result.inventory_filter = InventoryFilter(prefix=prefix, last_modify_begin_time_stamp=last_modify_begin_time_stamp,
  1261. last_modify_end_time_stamp=last_modify_end_time_stamp, lower_size_bound=lower_size_bound,
  1262. upper_size_bound=upper_size_bound, storage_class=storage_class)
  1263. if root.find("Schedule/Frequency") is not None:
  1264. result.inventory_schedule = InventorySchedule(_find_tag(root, 'Schedule/Frequency'))
  1265. result.optional_fields = _find_all_tags(root, "OptionalFields/Field")
  1266. if root.find("Destination/OSSBucketDestination") is not None:
  1267. bucket_distin_node = root.find("Destination/OSSBucketDestination")
  1268. account_id = None
  1269. role_arn = None
  1270. bucket = None
  1271. inventory_format = None
  1272. prefix = None
  1273. sse_kms_encryption = None
  1274. sse_oss_encryption = None
  1275. if bucket_distin_node.find('AccountId') is not None:
  1276. account_id = _find_tag(bucket_distin_node, 'AccountId')
  1277. if bucket_distin_node.find('RoleArn') is not None:
  1278. role_arn = _find_tag(bucket_distin_node, 'RoleArn')
  1279. if bucket_distin_node.find('Bucket') is not None:
  1280. origin_bucket = _find_tag(bucket_distin_node, 'Bucket')
  1281. if origin_bucket.startswith('acs:oss:::'):
  1282. bucket = origin_bucket.replace('acs:oss:::', '')
  1283. if bucket_distin_node.find('Format') is not None:
  1284. inventory_format = _find_tag(bucket_distin_node, 'Format')
  1285. if bucket_distin_node.find('Prefix') is not None:
  1286. prefix = _find_tag(bucket_distin_node, 'Prefix')
  1287. sse_kms_node = bucket_distin_node.find("Encryption/SSE-KMS")
  1288. if sse_kms_node is not None:
  1289. sse_kms_encryption = InventoryServerSideEncryptionKMS(_find_tag(sse_kms_node, 'KeyId'))
  1290. elif bucket_distin_node.find("Encryption/SSE-OSS") is not None:
  1291. sse_oss_encryption = InventoryServerSideEncryptionOSS()
  1292. bucket_destination = InventoryBucketDestination(account_id=account_id, role_arn=role_arn,
  1293. bucket=bucket, inventory_format=inventory_format, prefix=prefix,
  1294. sse_kms_encryption=sse_kms_encryption, sse_oss_encryption=sse_oss_encryption)
  1295. result.inventory_destination = InventoryDestination(bucket_destination)
  1296. return result
  1297. def parse_get_bucket_inventory_configuration(result, body):
  1298. root = ElementTree.fromstring(body)
  1299. inventory_config = get_Inventory_configuration_from_element(root)
  1300. result.inventory_id = inventory_config.inventory_id
  1301. result.is_enabled = inventory_config.is_enabled
  1302. result.included_object_versions = inventory_config.included_object_versions
  1303. result.inventory_filter = inventory_config.inventory_filter
  1304. result.inventory_schedule = inventory_config.inventory_schedule
  1305. result.optional_fields = inventory_config.optional_fields
  1306. result.inventory_destination = inventory_config.inventory_destination
  1307. return result
  1308. def parse_list_bucket_inventory_configurations(result, body):
  1309. root = ElementTree.fromstring(body)
  1310. for inventory_config_node in root.findall("InventoryConfiguration"):
  1311. inventory_config = get_Inventory_configuration_from_element(inventory_config_node)
  1312. result.inventory_configurations.append(inventory_config)
  1313. if root.find("ContinuationToken") is not None:
  1314. result.continuaiton_token = _find_tag(root, "ContinuationToken")
  1315. if root.find("IsTruncated") is not None:
  1316. result.is_truncated = _find_bool(root, "IsTruncated")
  1317. if root.find("NextContinuationToken") is not None:
  1318. result.next_continuation_token = _find_tag(root, "NextContinuationToken")
  1319. return result
  1320. def to_put_restore_config(restore_config):
  1321. root = ElementTree.Element('RestoreRequest')
  1322. _add_text_child(root, 'Days', str(restore_config.days))
  1323. if restore_config.job_parameters is not None:
  1324. job_parameters = restore_config.job_parameters
  1325. job_parameters_node = ElementTree.SubElement(root, "JobParameters")
  1326. if job_parameters.tier is not None:
  1327. _add_text_child(job_parameters_node, 'Tier', job_parameters.tier)
  1328. return _node_to_string(root)
  1329. def parse_get_bucket_worm_result(result, body):
  1330. root = ElementTree.fromstring(body)
  1331. result.worm_id = _find_tag(root, "WormId")
  1332. result.state = _find_tag(root, "State")
  1333. result.retention_period_days = _find_int(root, "RetentionPeriodInDays")
  1334. result.creation_date = _find_tag(root, "CreationDate")
  1335. def to_put_extend_bucket_worm(retention_period_days):
  1336. root = ElementTree.Element('ExtendWormConfiguration')
  1337. _add_text_child(root, 'RetentionPeriodInDays', str(retention_period_days))
  1338. return _node_to_string(root)
  1339. def to_put_init_bucket_worm(retention_period_days):
  1340. root = ElementTree.Element('InitiateWormConfiguration')
  1341. _add_text_child(root, 'RetentionPeriodInDays', str(retention_period_days))
  1342. return _node_to_string(root)
  1343. def to_put_bucket_replication(replication_config):
  1344. root = ElementTree.Element('ReplicationConfiguration')
  1345. rule = ElementTree.SubElement(root, 'Rule')
  1346. if replication_config.rule_id:
  1347. _add_text_child(rule, 'ID', replication_config.rule_id)
  1348. destination = ElementTree.SubElement(rule, 'Destination')
  1349. _add_text_child(destination, 'Bucket', replication_config.target_bucket_name)
  1350. _add_text_child(destination, 'Location', replication_config.target_bucket_location)
  1351. if replication_config.target_transfer_type:
  1352. _add_text_child(destination, 'TransferType', replication_config.target_transfer_type)
  1353. if replication_config.is_enable_historical_object_replication is False:
  1354. _add_text_child(rule, 'HistoricalObjectReplication', 'disabled')
  1355. else:
  1356. _add_text_child(rule, 'HistoricalObjectReplication', 'enabled')
  1357. if replication_config.prefix_list:
  1358. prefix_list_node = ElementTree.SubElement(rule, 'PrefixSet')
  1359. for prefix in replication_config.prefix_list:
  1360. _add_text_child(prefix_list_node, 'Prefix', prefix)
  1361. if replication_config.action_list:
  1362. actions = ''
  1363. for action in replication_config.action_list:
  1364. actions += action
  1365. actions += ','
  1366. actions = actions[:-1]
  1367. _add_text_child(rule, 'Action', actions)
  1368. if replication_config.sync_role_name:
  1369. _add_text_child(rule, 'SyncRole', replication_config.sync_role_name)
  1370. if replication_config.replica_kms_keyid:
  1371. encryption_config = ElementTree.SubElement(rule, 'EncryptionConfiguration')
  1372. _add_text_child(encryption_config, 'ReplicaKmsKeyID', replication_config.replica_kms_keyid)
  1373. if replication_config.sse_kms_encrypted_objects_status in ['Enabled', 'Disabled']:
  1374. criteria = ElementTree.SubElement(rule, 'SourceSelectionCriteria')
  1375. sse_kms_encrypted_objects = ElementTree.SubElement(criteria, 'SseKmsEncryptedObjects')
  1376. _add_text_child(sse_kms_encrypted_objects, 'Status', replication_config.sse_kms_encrypted_objects_status)
  1377. return _node_to_string(root)
  1378. def to_delete_bucket_replication(rule_id):
  1379. root = ElementTree.Element('ReplicationRules')
  1380. _add_text_child(root, 'ID', rule_id)
  1381. return _node_to_string(root)
  1382. def parse_get_bucket_replication_result(result, body):
  1383. root = ElementTree.fromstring(body)
  1384. for rule_node in root.findall("Rule"):
  1385. rule = ReplicationRule()
  1386. if rule_node.find("ID") is not None:
  1387. rule.rule_id = _find_tag(rule_node, "ID")
  1388. destination_node = rule_node.find("Destination")
  1389. rule.target_bucket_name = _find_tag_with_default(destination_node, "Bucket", None)
  1390. rule.target_bucket_location = _find_tag_with_default(destination_node, "Location", None)
  1391. rule.target_transfer_type = _find_tag_with_default(destination_node, "TransferType", None)
  1392. rule.target_cloud = _find_tag_with_default(destination_node, "Cloud", None)
  1393. rule.target_cloud_location = _find_tag_with_default(destination_node, "CloudLocation", None)
  1394. rule.status = _find_tag(rule_node, "Status")
  1395. rule.sync_role_name = _find_tag_with_default(rule_node, 'SyncRole', None)
  1396. rule.replica_kms_keyid = _find_tag_with_default(rule_node, 'EncryptionConfiguration/ReplicaKmsKeyID', None)
  1397. rule.sse_kms_encrypted_objects_status = _find_tag_with_default(rule_node, 'SourceSelectionCriteria/SseKmsEncryptedObjects/Status', None)
  1398. if _find_tag(rule_node, "HistoricalObjectReplication") == 'enabled':
  1399. rule.is_enable_historical_object_replication = True
  1400. else:
  1401. rule.is_enable_historical_object_replication = False
  1402. prefixes_node = rule_node.find('PrefixSet')
  1403. if prefixes_node is not None:
  1404. rule.prefix_list = _find_all_tags(prefixes_node, 'Prefix')
  1405. actions = _find_tag(rule_node, 'Action')
  1406. rule.action_list = actions.split(',')
  1407. result.rule_list.append(rule)
  1408. def parse_get_bucket_replication_location_result(result, body):
  1409. root = ElementTree.fromstring(body)
  1410. result.location_list = _find_all_tags(root, "Location")
  1411. if root.find("LocationTransferTypeConstraint") is not None:
  1412. constraint_node = root.find("LocationTransferTypeConstraint")
  1413. for transfer_type_node in constraint_node.findall("LocationTransferType"):
  1414. location_transfer_type = LocationTransferType()
  1415. location_transfer_type.location = _find_tag_with_default(transfer_type_node, "Location", None)
  1416. location_transfer_type.transfer_type = _find_tag_with_default(transfer_type_node, "TransferTypes/Type", None)
  1417. result.location_transfer_type_list.append(location_transfer_type)
  1418. def parse_get_bucket_replication_progress_result(result, body):
  1419. root = ElementTree.fromstring(body)
  1420. rule_node = root.find("Rule")
  1421. progress = BucketReplicationProgress()
  1422. progress.rule_id = _find_tag(rule_node, "ID")
  1423. destination_node = rule_node.find("Destination")
  1424. progress.target_bucket_name = _find_tag(destination_node, "Bucket")
  1425. progress.target_bucket_location = _find_tag(destination_node, "Location")
  1426. progress.target_transfer_type = _find_tag_with_default(destination_node, "TransferType", None)
  1427. progress.status = _find_tag(rule_node, "Status")
  1428. if _find_tag(rule_node, "HistoricalObjectReplication") == 'enabled':
  1429. progress.is_enable_historical_object_replication = True
  1430. else:
  1431. progress.is_enable_historical_object_replication = False
  1432. prefixes_node = rule_node.find('PrefixSet')
  1433. if prefixes_node is not None:
  1434. progress.prefix_list = _find_all_tags(prefixes_node, 'Prefix')
  1435. actions = _find_tag(rule_node, 'Action')
  1436. progress.action_list = actions.split(',')
  1437. historical_object_progress = _find_tag_with_default(rule_node, 'Progress/HistoricalObject', None)
  1438. if historical_object_progress is not None:
  1439. progress.historical_object_progress = float(historical_object_progress)
  1440. progress.new_object_progress = _find_tag_with_default(rule_node, 'Progress/NewObject', None)
  1441. result.progress = progress
  1442. def to_put_bucket_transfer_acceleration(enabled):
  1443. root = ElementTree.Element('TransferAccelerationConfiguration')
  1444. _add_text_child(root, 'Enabled', str(enabled))
  1445. return _node_to_string(root)
  1446. def parse_get_bucket_transfer_acceleration_result(result, body):
  1447. root = ElementTree.fromstring(body)
  1448. result.enabled = _find_tag(root, "Enabled")
  1449. def to_bucket_cname_configuration(domain, cert=None):
  1450. root = ElementTree.Element("BucketCnameConfiguration")
  1451. cname = ElementTree.SubElement(root, 'Cname')
  1452. _add_text_child(cname, 'Domain', domain)
  1453. if cert is not None:
  1454. certificate = ElementTree.SubElement(cname, 'CertificateConfiguration')
  1455. if cert.cert_id is not None:
  1456. _add_text_child(certificate, 'CertId', cert.cert_id)
  1457. if cert.certificate is not None:
  1458. _add_text_child(certificate, 'Certificate', cert.certificate)
  1459. if cert.private_key is not None:
  1460. _add_text_child(certificate, 'PrivateKey',cert.private_key)
  1461. if cert.previous_cert_id is not None:
  1462. _add_text_child(certificate, 'PreviousCertId', cert.previous_cert_id)
  1463. if cert.force is not None:
  1464. _add_text_child(certificate, 'Force', str(cert.force))
  1465. if cert.delete_certificate is not None:
  1466. _add_text_child(certificate, 'DeleteCertificate', str(cert.delete_certificate))
  1467. return _node_to_string(root)
  1468. def parse_create_bucket_cname_token(result, body):
  1469. root = ElementTree.fromstring(body)
  1470. result.bucket = _find_tag(root, "Bucket")
  1471. result.cname = _find_tag(root, "Cname")
  1472. result.token = _find_tag(root, "Token")
  1473. result.expire_time = _find_tag(root, "ExpireTime")
  1474. def parse_get_bucket_cname_token(result, body):
  1475. root = ElementTree.fromstring(body)
  1476. result.bucket = _find_tag(root, "Bucket")
  1477. result.cname = _find_tag(root, "Cname")
  1478. result.token = _find_tag(root, "Token")
  1479. result.expire_time = _find_tag(root, "ExpireTime")
  1480. def parse_list_bucket_cname(result, body):
  1481. root = ElementTree.fromstring(body)
  1482. result.bucket = _find_tag(root, "Bucket")
  1483. result.owner = _find_tag(root, "Owner")
  1484. for cname in root.findall('Cname'):
  1485. tmp = CnameInfo()
  1486. tmp.domain = _find_tag_with_default(cname, 'Domain', None)
  1487. tmp.last_modified = _find_tag_with_default(cname, 'LastModified', None)
  1488. tmp.status = _find_tag_with_default(cname, 'Status', None)
  1489. tmp.is_purge_cdn_cache = _find_tag_with_default(cname, 'IsPurgeCdnCache', None)
  1490. cert = cname.find('Certificate')
  1491. if cert is not None:
  1492. certificate = CertificateInfo()
  1493. certificate.type = _find_tag_with_default(cert, 'Type', None)
  1494. certificate.cert_id = _find_tag_with_default(cert, 'CertId', None)
  1495. certificate.status = _find_tag_with_default(cert, 'Status', None)
  1496. certificate.creation_date = _find_tag_with_default(cert, 'CreationDate', None)
  1497. certificate.fingerprint = _find_tag_with_default(cert, 'Fingerprint', None)
  1498. certificate.valid_start_date = _find_tag_with_default(cert, 'ValidStartDate', None)
  1499. certificate.valid_end_date = _find_tag_with_default(cert, 'ValidEndDate', None)
  1500. tmp.certificate = certificate
  1501. result.cname.append(tmp)
  1502. def to_do_bucket_meta_query_request(meta_query):
  1503. root = ElementTree.Element("MetaQuery")
  1504. if meta_query.next_token is not None:
  1505. _add_text_child(root, "NextToken", meta_query.next_token)
  1506. _add_text_child(root, "MaxResults", meta_query.max_results)
  1507. _add_text_child(root, "Query", meta_query.query)
  1508. if meta_query.sort is not None:
  1509. _add_text_child(root, "Sort", meta_query.sort)
  1510. if meta_query.order is not None:
  1511. _add_text_child(root, "Order", meta_query.order)
  1512. if meta_query.aggregations:
  1513. aggregations_node = ElementTree.SubElement(root, "Aggregations")
  1514. for aggregation in meta_query.aggregations:
  1515. aggregation_node = ElementTree.SubElement(aggregations_node, 'Aggregation')
  1516. if aggregation.field is not None:
  1517. _add_text_child(aggregation_node, 'Field', aggregation.field)
  1518. if aggregation.operation is not None:
  1519. _add_text_child(aggregation_node, 'Operation', aggregation.operation)
  1520. return _node_to_string(root)
  1521. def parse_get_bucket_meta_query_result(result, body):
  1522. root = ElementTree.fromstring(body)
  1523. result.state = _find_tag(root, "State")
  1524. result.phase = _find_tag(root, "Phase")
  1525. result.create_time = _find_tag(root, "CreateTime")
  1526. result.update_time = _find_tag(root, "UpdateTime")
  1527. def parse_do_bucket_meta_query_result(result, body):
  1528. root = ElementTree.fromstring(body)
  1529. result.next_token = _find_tag(root, "NextToken")
  1530. for file in root.findall('Files/File'):
  1531. tmp = MetaQueryFile()
  1532. tmp.file_name = _find_tag(file, 'Filename')
  1533. tmp.size = int(_find_tag_with_default(file, 'Size', 0))
  1534. tmp.file_modified_time = _find_tag_with_default(file, 'FileModifiedTime', None)
  1535. tmp.file_create_time = _find_tag_with_default(file, 'FileCreateTime', None)
  1536. tmp.file_access_time = _find_tag_with_default(file, 'FileAccessTime', None)
  1537. tmp.oss_object_type = _find_tag_with_default(file, 'OSSObjectType', None)
  1538. tmp.oss_storage_class = _find_tag_with_default(file, 'OSSStorageClass', None)
  1539. tmp.object_acl = _find_tag_with_default(file, 'ObjectACL', None)
  1540. tmp.etag = _find_tag_with_default(file, 'ETag', None)
  1541. tmp.oss_crc64 = _find_tag_with_default(file, 'OSSCRC64', None)
  1542. tmp.oss_tagging_count = int(_find_tag_with_default(file, 'OSSTaggingCount', 0))
  1543. if file.find('OSSTagging') is not None:
  1544. for tagging in file.find('OSSTagging').findall('Tagging'):
  1545. tmp_tagging = OSSTaggingInfo(_find_tag(tagging, 'Key'), _find_tag(tagging, 'Value'))
  1546. tmp.oss_tagging.append(tmp_tagging)
  1547. if file.find('OSSUserMeta') is not None:
  1548. for meta in file.find('OSSUserMeta').findall('UserMeta'):
  1549. tmp_meta = OSSUserMetaInfo(_find_tag(meta, 'Key'), _find_tag(meta, 'Value'))
  1550. tmp.oss_user_meta.append(tmp_meta)
  1551. result.files.append(tmp)
  1552. for aggregation in root.findall('Aggregations/Aggregation'):
  1553. tmp = AggregationsInfo()
  1554. tmp.field = _find_tag(aggregation, 'Field')
  1555. tmp.operation = _find_tag(aggregation, 'Operation')
  1556. tmp.value = float(_find_tag_with_default(aggregation, 'Value', 0))
  1557. for group in aggregation.findall('Groups/Group'):
  1558. tmp_groups = AggregationGroupInfo(_find_tag(group, 'Value'), int(_find_tag_with_default(group, 'Count', 0)))
  1559. tmp.groups.append(tmp_groups)
  1560. result.aggregations.append(tmp)
  1561. def parse_dummy_result(result, body):
  1562. return result
  1563. def to_put_bucket_access_monitor(status):
  1564. root = ElementTree.Element('AccessMonitorConfiguration')
  1565. _add_text_child(root, 'Status', status)
  1566. return _node_to_string(root)
  1567. def parse_get_bucket_access_monitor_result(result, body):
  1568. root = ElementTree.fromstring(body)
  1569. access_monitor = AccessMonitorInfo(_find_tag(root, "Status"))
  1570. result.access_monitor = access_monitor
  1571. def parse_lifecycle_filter(filter_node):
  1572. lifecycle_filter = LifecycleFilter()
  1573. if filter_node is not None:
  1574. if filter_node.find('ObjectSizeGreaterThan') is not None:
  1575. lifecycle_filter.object_size_greater_than = int(_find_tag_with_default(filter_node, 'ObjectSizeGreaterThan', 0))
  1576. if filter_node.find('ObjectSizeLessThan') is not None:
  1577. lifecycle_filter.object_size_less_than = int(_find_tag_with_default(filter_node, 'ObjectSizeLessThan', 0))
  1578. not_nodes = filter_node.findall('Not')
  1579. if not_nodes is not None:
  1580. for not_node in not_nodes:
  1581. prefix = _find_tag_with_default(not_node, 'Prefix', None)
  1582. key = _find_tag_with_default(not_node, 'Tag/Key', None)
  1583. value = _find_tag_with_default(not_node, 'Tag/Value', None)
  1584. tag = FilterNotTag(key, value)
  1585. filter_not = FilterNot(prefix, tag)
  1586. lifecycle_filter.filter_not.append(filter_not)
  1587. return lifecycle_filter
  1588. def to_put_bucket_resource_group(resourceGroupId):
  1589. root = ElementTree.Element('BucketResourceGroupConfiguration')
  1590. _add_text_child(root, 'ResourceGroupId', resourceGroupId)
  1591. return _node_to_string(root)
  1592. def parse_get_bucket_resource_group_result(result, body):
  1593. root = ElementTree.fromstring(body)
  1594. result.resource_group_id = _find_tag(root, "ResourceGroupId")
  1595. def to_put_bucket_style(content):
  1596. root = ElementTree.Element('Style')
  1597. _add_text_child(root, 'Content', content)
  1598. return _node_to_string(root)
  1599. def parse_get_bucket_style_result(result, body):
  1600. root = ElementTree.fromstring(body)
  1601. result.name = _find_tag(root, "Name")
  1602. result.content = _find_tag(root, "Content")
  1603. result.create_time = _find_tag(root, "CreateTime")
  1604. result.last_modify_time = _find_tag(root, "LastModifyTime")
  1605. def parse_list_bucket_style(result, body):
  1606. root = ElementTree.fromstring(body)
  1607. for style in root.findall('Style'):
  1608. tmp = BucketStyleInfo()
  1609. tmp.name = _find_tag_with_default(style, 'Name', None)
  1610. tmp.content = _find_tag_with_default(style, 'Content', None)
  1611. tmp.create_time = _find_tag_with_default(style, 'CreateTime', None)
  1612. tmp.last_modify_time = _find_tag_with_default(style, 'LastModifyTime', None)
  1613. result.styles.append(tmp)
  1614. def parse_describe_regions(result, body):
  1615. root = ElementTree.fromstring(body)
  1616. for region in root.findall('RegionInfo'):
  1617. tmp = RegionInfo()
  1618. tmp.region = _find_tag_with_default(region, 'Region', None)
  1619. tmp.internet_endpoint = _find_tag_with_default(region, 'InternetEndpoint', None)
  1620. tmp.internal_endpoint = _find_tag_with_default(region, 'InternalEndpoint', None)
  1621. tmp.accelerate_endpoint = _find_tag_with_default(region, 'AccelerateEndpoint', None)
  1622. result.regions.append(tmp)
  1623. def parse_async_process_object(result, body):
  1624. if body:
  1625. body_dict = json.loads(to_unicode(body))
  1626. result.event_id = body_dict['EventId']
  1627. result.async_request_id = body_dict['RequestId']
  1628. result.task_id = body_dict['TaskId']
  1629. return result
  1630. def to_do_bucket_callback_policy_request(callback_policy):
  1631. root = ElementTree.Element("BucketCallbackPolicy")
  1632. if callback_policy:
  1633. for policy in callback_policy:
  1634. if policy:
  1635. policy_node = ElementTree.SubElement(root, 'PolicyItem')
  1636. if policy.policy_name is not None:
  1637. _add_text_child(policy_node, 'PolicyName', policy.policy_name)
  1638. if policy.callback is not None:
  1639. _add_text_child(policy_node, 'Callback', policy.callback)
  1640. if policy.callback_var is None:
  1641. _add_text_child(policy_node, 'CallbackVar', '')
  1642. else:
  1643. _add_text_child(policy_node, 'CallbackVar', policy.callback_var)
  1644. return _node_to_string(root)
  1645. def parse_callback_policy_result(result, body):
  1646. root = ElementTree.fromstring(body)
  1647. for policy in root.findall('PolicyItem'):
  1648. tmp = CallbackPolicyInfo()
  1649. tmp.policy_name = _find_tag_with_default(policy, 'PolicyName', None)
  1650. tmp.callback = _find_tag_with_default(policy, 'Callback', None)
  1651. tmp.callback_var = _find_tag_with_default(policy, 'CallbackVar', None)
  1652. result.callback_policies.append(tmp)
  1653. def to_put_bucket_archive_direct_read(enabled):
  1654. root = ElementTree.Element('ArchiveDirectReadConfiguration')
  1655. _add_text_child(root, 'Enabled', str(enabled).lower())
  1656. return _node_to_string(root)
  1657. def parse_get_bucket_archive_direct_read(result, body):
  1658. root = ElementTree.fromstring(body)
  1659. if root.find("Enabled") is not None:
  1660. result.enabled = _find_bool(root, "Enabled")
  1661. def to_do_bucket_https_config_request(https_config):
  1662. root = ElementTree.Element('HttpsConfiguration')
  1663. list_node = ElementTree.SubElement(root, 'TLS')
  1664. _add_text_child(list_node, 'Enable', str(https_config.tls_enabled).lower())
  1665. if https_config.tls_version:
  1666. for r in https_config.tls_version:
  1667. _add_text_child(list_node, 'TLSVersion', r)
  1668. return _node_to_string(root)
  1669. def parse_get_bucket_https_config(result, body):
  1670. root = ElementTree.fromstring(body)
  1671. result.tls_enabled = _find_bool(root, 'TLS/Enable')
  1672. if root.find("TLS/TLSVersion") is not None:
  1673. result.tls_version = _find_all_tags(root, 'TLS/TLSVersion')
  1674. return result
  1675. def parse_create_data_redundancy_transition_result(result, body):
  1676. root = ElementTree.fromstring(body)
  1677. result.task_id = _find_tag_with_default(root, "TaskId", None)
  1678. def parse_data_redundancy_transition(transition_node):
  1679. if transition_node is None:
  1680. return None
  1681. transition = DataRedundancyTransitionInfo()
  1682. if transition_node.find('Bucket') is not None:
  1683. transition.bucket = _find_tag_with_default(transition_node, 'Bucket', None)
  1684. if transition_node.find('TaskId') is not None:
  1685. transition.task_id = _find_tag_with_default(transition_node, 'TaskId', None)
  1686. if transition_node.find('Status') is not None:
  1687. transition.transition_status = _find_tag_with_default(transition_node, 'Status', None)
  1688. if transition_node.find('CreateTime') is not None:
  1689. transition.create_time = _find_tag_with_default(transition_node, 'CreateTime', None)
  1690. if transition_node.find('StartTime') is not None:
  1691. transition.start_time = _find_tag_with_default(transition_node, 'StartTime', None)
  1692. if transition_node.find('EndTime') is not None:
  1693. transition.end_time = _find_tag_with_default(transition_node, 'EndTime', None)
  1694. if transition_node.find('EstimatedRemainingTime') is not None:
  1695. transition.estimated_remaining_time = _find_int(transition_node, 'EstimatedRemainingTime')
  1696. if transition_node.find('ProcessPercentage') is not None:
  1697. transition.process_percentage = _find_int(transition_node, 'ProcessPercentage')
  1698. return transition
  1699. def parse_get_bucket_data_redundancy_transition(result, body):
  1700. root = ElementTree.fromstring(body)
  1701. if root.find('Bucket') is not None:
  1702. result.bucket = _find_tag_with_default(root, 'Bucket', None)
  1703. if root.find('TaskId') is not None:
  1704. result.task_id = _find_tag_with_default(root, 'TaskId', None)
  1705. if root.find('Status') is not None:
  1706. result.transition_status = _find_tag_with_default(root, 'Status', None)
  1707. if root.find('CreateTime') is not None:
  1708. result.create_time = _find_tag_with_default(root, 'CreateTime', None)
  1709. if root.find('StartTime') is not None:
  1710. result.start_time = _find_tag_with_default(root, 'StartTime', None)
  1711. if root.find('EndTime') is not None:
  1712. result.end_time = _find_tag_with_default(root, 'EndTime', None)
  1713. if root.find('EstimatedRemainingTime') is not None:
  1714. result.estimated_remaining_time = _find_int(root, 'EstimatedRemainingTime')
  1715. if root.find('ProcessPercentage') is not None:
  1716. result.process_percentage = _find_int(root, 'ProcessPercentage')
  1717. def parse_list_bucket_data_redundancy_transition(result, body):
  1718. root = ElementTree.fromstring(body)
  1719. for transition in root.findall('BucketDataRedundancyTransition'):
  1720. tmp = parse_data_redundancy_transition(transition)
  1721. result.data_redundancy_transitions.append(tmp)
  1722. def parse_list_user_data_redundancy_transition(result, body):
  1723. root = ElementTree.fromstring(body)
  1724. if root.find("IsTruncated") is not None:
  1725. result.is_truncated = _find_bool(root, "IsTruncated")
  1726. if root.find("NextContinuationToken") is not None:
  1727. result.next_continuation_token = _find_tag(root, "NextContinuationToken")
  1728. for transition in root.findall('BucketDataRedundancyTransition'):
  1729. tmp = parse_data_redundancy_transition(transition)
  1730. result.data_redundancy_transitions.append(tmp)
  1731. def to_do_create_access_point_request(accessPoint):
  1732. root = ElementTree.Element("CreateAccessPointConfiguration")
  1733. if accessPoint.access_point_name is not None:
  1734. _add_text_child(root, "AccessPointName", accessPoint.access_point_name)
  1735. if accessPoint.network_origin is not None:
  1736. _add_text_child(root, "NetworkOrigin", accessPoint.network_origin)
  1737. if accessPoint.vpc is not None:
  1738. vpc_node = ElementTree.SubElement(root, "VpcConfiguration")
  1739. _add_text_child(vpc_node, "VpcId", accessPoint.vpc.vpc_id)
  1740. return _node_to_string(root)
  1741. def parse_create_access_point_result(result, body):
  1742. root = ElementTree.fromstring(body)
  1743. result.access_point_arn = _find_tag_with_default(root, "AccessPointArn", None)
  1744. result.alias = _find_tag_with_default(root, "Alias", None)
  1745. def parse_get_access_point_result(result, body):
  1746. root = ElementTree.fromstring(body)
  1747. result.access_point_name = _find_tag_with_default(root, "AccessPointName", None)
  1748. result.bucket = _find_tag_with_default(root, "Bucket", None)
  1749. result.account_id = _find_tag_with_default(root, "AccountId", None)
  1750. result.network_origin = _find_tag_with_default(root, "NetworkOrigin", None)
  1751. vpc_node = root.find('VpcConfiguration')
  1752. if vpc_node is not None:
  1753. vpc = AccessPointVpcConfiguration()
  1754. vpc.vpc_id = _find_tag_with_default(vpc_node, "VpcId", None)
  1755. result.vpc = vpc
  1756. result.access_point_arn = _find_tag_with_default(root, "AccessPointArn", None)
  1757. result.creation_date = _find_tag_with_default(root, "CreationDate", None)
  1758. result.alias = _find_tag_with_default(root, "Alias", None)
  1759. result.access_point_status = _find_tag_with_default(root, "Status", None)
  1760. endpoint_node = root.find('Endpoints')
  1761. if endpoint_node is not None:
  1762. endpoint = AccessPointEndpoints()
  1763. endpoint.public_endpoint = _find_tag_with_default(endpoint_node, "PublicEndpoint", None)
  1764. endpoint.internal_endpoint = _find_tag_with_default(endpoint_node, "InternalEndpoint", None)
  1765. result.endpoints = endpoint
  1766. block_node = root.find('PublicAccessBlockConfiguration')
  1767. if block_node is not None:
  1768. block = PublicAccessBlockConfiguration()
  1769. if block_node.find('BlockPublicAccess') is not None:
  1770. block.block_public_access = _find_bool(block_node, "BlockPublicAccess")
  1771. result.public_access_block_configuration = block
  1772. def parse_list_access_point_result(result, body):
  1773. root = ElementTree.fromstring(body)
  1774. result.account_id = _find_tag_with_default(root, 'AccountId', None)
  1775. result.marker = _find_tag_with_default(root, 'Marker', None)
  1776. result.max_keys = _find_int(root, 'MaxKeys')
  1777. result.is_truncated = _find_bool(root, 'IsTruncated')
  1778. if result.is_truncated is not None:
  1779. result.next_continuation_token = _find_tag_with_default(root, 'NextContinuationToken', None)
  1780. access_points = root.findall('AccessPoints/AccessPoint')
  1781. for access_point in access_points:
  1782. tmp = AccessPointInfo()
  1783. tmp.bucket = _find_tag(access_point, 'Bucket')
  1784. tmp.access_point_name = _find_tag(access_point, 'AccessPointName')
  1785. tmp.alias = _find_tag(access_point, 'Alias')
  1786. tmp.status = _find_tag(access_point, 'Status')
  1787. tmp.network_origin = _find_tag(access_point, 'NetworkOrigin')
  1788. vpc_node = access_point.find('VpcConfiguration')
  1789. if vpc_node is not None:
  1790. vpc = AccessPointVpcConfiguration()
  1791. vpc.vpc_id = _find_tag_with_default(vpc_node, "VpcId", None)
  1792. tmp.vpc = vpc
  1793. result.access_points.append(tmp)
  1794. return result
  1795. def to_put_public_access_block_request(block_public_access):
  1796. root = ElementTree.Element('PublicAccessBlockConfiguration')
  1797. _add_text_child(root, 'BlockPublicAccess', str(block_public_access))
  1798. return _node_to_string(root)
  1799. def parse_get_public_access_block_result(result, body):
  1800. root = ElementTree.fromstring(body)
  1801. if root.find("BlockPublicAccess") is not None:
  1802. result.block_public_access = _find_bool(root, 'BlockPublicAccess')
  1803. def parse_qos_configuration(qos_info_node):
  1804. if qos_info_node is None:
  1805. return None
  1806. qos = QoSConfiguration()
  1807. if qos_info_node.find('TotalUploadBandwidth') is not None:
  1808. qos.total_upload_bw = _find_int(qos_info_node, 'TotalUploadBandwidth')
  1809. if qos_info_node.find('IntranetUploadBandwidth') is not None:
  1810. qos.intranet_upload_bw = _find_int(qos_info_node, 'IntranetUploadBandwidth')
  1811. if qos_info_node.find('ExtranetUploadBandwidth') is not None:
  1812. qos.extranet_upload_bw = _find_int(qos_info_node, 'ExtranetUploadBandwidth')
  1813. if qos_info_node.find('TotalDownloadBandwidth') is not None:
  1814. qos.total_download_bw = _find_int(qos_info_node, 'TotalDownloadBandwidth')
  1815. if qos_info_node.find('IntranetDownloadBandwidth') is not None:
  1816. qos.intranet_download_bw = _find_int(qos_info_node, 'IntranetDownloadBandwidth')
  1817. if qos_info_node.find('ExtranetDownloadBandwidth') is not None:
  1818. qos.extranet_download_bw = _find_int(qos_info_node, 'ExtranetDownloadBandwidth')
  1819. if qos_info_node.find('TotalQps') is not None:
  1820. qos.total_qps = _find_int(qos_info_node, 'TotalQps')
  1821. if qos_info_node.find('IntranetQps') is not None:
  1822. qos.intranet_qps = _find_int(qos_info_node, 'IntranetQps')
  1823. if qos_info_node.find('ExtranetQps') is not None:
  1824. qos.extranet_qps = _find_int(qos_info_node, 'ExtranetQps')
  1825. return qos
  1826. def to_put_bucket_requester_qos_info(enabled):
  1827. root = ElementTree.Element('QoSConfiguration')
  1828. _add_text_child(root, 'Enabled', str(enabled).lower())
  1829. return _node_to_string(root)
  1830. def parse_get_requester_qos_info(result, body):
  1831. root = ElementTree.fromstring(body)
  1832. result.requester = _find_tag_with_default(root, 'Requester', None)
  1833. result.qos_configuration = parse_qos_configuration(root.find('QoSConfiguration'))
  1834. return result
  1835. def parse_get_resource_pool_info(result, body):
  1836. root = ElementTree.fromstring(body)
  1837. result.region = _find_tag_with_default(root, 'Region', None)
  1838. result.name = _find_tag_with_default(root, 'Name', None)
  1839. result.owner = _find_tag_with_default(root, 'Owner', None)
  1840. result.create_time = _find_tag_with_default(root, 'CreateTime', None)
  1841. result.qos_configuration = parse_qos_configuration(root.find('QoSConfiguration'))
  1842. return result
  1843. def parse_list_resource_pools(result, body):
  1844. root = ElementTree.fromstring(body)
  1845. result.region = _find_tag_with_default(root, 'Region', None)
  1846. result.owner = _find_tag_with_default(root, 'Owner', None)
  1847. result.continuation_token = _find_tag_with_default(root, 'ContinuationToken', None)
  1848. result.next_continuation_token = _find_tag_with_default(root, 'NextContinuationToken', None)
  1849. result.is_truncated = _find_bool(root, 'IsTruncated')
  1850. for resource in root.findall('ResourcePool'):
  1851. tmp = ResourcePoolInfo()
  1852. tmp.name = _find_tag_with_default(resource, 'Name', None)
  1853. tmp.create_time = _find_tag_with_default(resource, 'CreateTime', None)
  1854. result.resource_pool.append(tmp)
  1855. return result
  1856. def parse_list_resource_pool_buckets(result, body):
  1857. root = ElementTree.fromstring(body)
  1858. result.resource_pool = _find_tag_with_default(root, 'ResourcePool', None)
  1859. result.continuation_token = _find_tag_with_default(root, 'ContinuationToken', None)
  1860. result.next_continuation_token = _find_tag_with_default(root, 'NextContinuationToken', None)
  1861. result.is_truncated = _find_bool(root, 'IsTruncated')
  1862. for bucket in root.findall('ResourcePoolBucket'):
  1863. tmp = ResourcePoolBucketInfo()
  1864. tmp.name = _find_tag_with_default(bucket, 'Name', None)
  1865. tmp.join_time = _find_tag_with_default(bucket, 'JoinTime', None)
  1866. result.resource_pool_buckets.append(tmp)
  1867. return result
  1868. def parse_list_resource_pool_requester_qos_infos(result, body):
  1869. root = ElementTree.fromstring(body)
  1870. result.resource_pool = _find_tag_with_default(root, 'ResourcePool', None)
  1871. result.continuation_token = _find_tag_with_default(root, 'ContinuationToken', None)
  1872. result.next_continuation_token = _find_tag_with_default(root, 'NextContinuationToken', None)
  1873. result.is_truncated = _find_bool(root, 'IsTruncated')
  1874. for qos_info in root.findall('RequesterQoSInfo'):
  1875. tmp = RequesterQoSInfo()
  1876. tmp.requester = _find_tag_with_default(qos_info, 'Requester', None)
  1877. tmp.qos_configuration = parse_qos_configuration(qos_info.find('QoSConfiguration'))
  1878. result.requester_qos_info.append(tmp)
  1879. return result
  1880. def parse_list_bucket_requester_qos_infos(result, body):
  1881. root = ElementTree.fromstring(body)
  1882. result.bucket = _find_tag_with_default(root, 'Bucket', None)
  1883. result.continuation_token = _find_tag_with_default(root, 'ContinuationToken', None)
  1884. result.next_continuation_token = _find_tag_with_default(root, 'NextContinuationToken', None)
  1885. result.is_truncated = _find_bool(root, 'IsTruncated')
  1886. for qos_info in root.findall('RequesterQoSInfo'):
  1887. tmp = RequesterQoSInfo()
  1888. tmp.requester = _find_tag_with_default(qos_info, 'Requester', None)
  1889. tmp.qos_configuration = parse_qos_configuration(qos_info.find('QoSConfiguration'))
  1890. result.requester_qos_info.append(tmp)
  1891. return result