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.. |
name: str
inherited
property
writable
¶
Name of the object via data['name']
if available.
data
inherited
property
writable
¶
Response data from the Celonis API.
If static
is set to False
, every time you set the data
property will execute a POST
request to
the resource API endpoint to update the remote resource in Celonis EMS.
Examples:
o = celonis.<api-service>.find("<name or ID")
# This will execute a `POST` request to '<celonis_url>/<api-service>/api/...'
o.data["name"] = "New Name"
key: str
inherited
property
writable
¶
Key of the object via data['key']
if available.
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. |
reset_state(self)
inherited
¶
Resets data = None
.
This will force a reload of the remote resource from Celonis EMS on the next property access.
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
json { "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. |
delete(self)
inherited
¶
Executes a DELETE
request to the resource API endpoint to delete the remote resource in Celonis EMS.
ExtractionTable (CelonisDataObject)
¶
name: str
inherited
property
writable
¶
Name of the object via data['name']
if available.
key: str
inherited
property
writable
¶
Key of the object via data['key']
if available.
data: Dict
property
readonly
¶
Extraction table data.
filter: Dict
property
readonly
¶
Extraction table filter Definition.
delta_filter: Dict
property
readonly
¶
Extraction table delta filter Definition.