pipeline.src.parsers.flux.sales_parsers

Attributes

NS_FLUX_SALES

Functions

`_find`(→ Optional[xml.etree.ElementTree.Element])
`_findall`(→ List[xml.etree.ElementTree.Element])
`_get`(→ Optional[str])
`_make_datetime`(date_str)
`parse_product`(→ dict)
`parse_sales_document`(→ Tuple[dict, dict, ...)	Parse IncludedSalesDocument.
`parse_sales_report_message_string`(→ Tuple[str, List[dict]])

Module Contents

pipeline.src.parsers.flux.sales_parsers.NS_FLUX_SALES[source]

pipeline.src.parsers.flux.sales_parsers._find(el: xml.etree.ElementTree.Element, path: str) → xml.etree.ElementTree.Element | None[source]

pipeline.src.parsers.flux.sales_parsers._findall(el: xml.etree.ElementTree.Element, path: str) → List[xml.etree.ElementTree.Element][source]

pipeline.src.parsers.flux.sales_parsers._get(el: xml.etree.ElementTree.Element, path: str) → str | None[source]

pipeline.src.parsers.flux.sales_parsers._make_datetime(date_str: str | None)[source]

pipeline.src.parsers.flux.sales_parsers.parse_product(product: xml.etree.ElementTree.Element, currency: str) → dict[source]

pipeline.src.parsers.flux.sales_parsers.parse_sales_document(doc: xml.etree.ElementTree.Element) → Tuple[dict, dict, str | None, str | None][source]

Parse IncludedSalesDocument.

Returns:: (value_dict, vessel_dict, trip_number, sales_datetime_utc_str)

pipeline.src.parsers.flux.sales_parsers.parse_sales_report_message_string(message_string: str) → Tuple[str, List[dict]][source]