data_extraction.py
Extraction (CelonisApiObjectChild)
¶
Extraction object to interact with Celonis Event Collection Extraction API.
url: str
property
readonly
¶
API
/integration/api/pools/{pool_id}/jobs/{job_id}/extractions/{extraction_id}/expanded
tables: CelonisCollection[ExtractionTable]
property
readonly
¶
Get all Tables from Extraction.
Returns:
Type | Description |
---|---|
CelonisCollection[ExtractionTable] |
Collection of Extraction Tables. |
variables: Dict
property
readonly
¶
Get all Pool Variables.
API
GET: /integration/api/pools/{pool_id}/tasks/{self.id}/variables/
Returns:
Type | Description |
---|---|
Dict |
Dictionary of Pool variables.. |
add_table(self, table, schema_name=None)
¶
Adds a table to the Extraction.
Parameters:
Name | Type | Description | Default |
---|---|---|---|
table |
Union[str, Dict, ExtractionTable] |
|
required |
schema_name |
str |
Schema name, as for example necessary for JDBC connections. |
None |
Returns:
Type | Description |
---|---|
ExtractionTable |
The newly created Extraction Table. |
create_extraction_parameter(self, variable)
¶
Creates a new Variable with the specified properties in the Extraction.
API
POST: /integration/api/pools/{pool_id}/tasks/{transformation_id}/variables
{ "dataType": "<DATE|DOUBLE|INT|STRING|COLUMN|QUALIFIED_COLUMN| LIST_DOUBLE|LIST_INT|LIST_STRING|NULL>", "name": "", "type": "<PRIVATE_CONSTANT|PUBLIC_CONSTANT|DYNAMIC>", "description": "", "settings": { "poolVariableID": "" }, "placeholder": "", "values": [ {"value": ""},... ], "defaultValues": [], "dynamicColumn": "", "dynamicTable": "", "dynamicVariableOpType": "<FIND_MAX|FIND_MIN|LIST>", "parameterType": "<CUSTOM|DATASOURCE>" }
Parameters:
Name | Type | Description | Default |
---|---|---|---|
variable |
Dict |
Dictionary. |
required |
Returns:
Type | Description |
---|---|
Dict |
The newly created Variable as Dictionary. |