Skip to content

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]
  • str: should be table name.
  • dict: should be dictionary with values: 
    {
    "schemaName": "",
    "tableName": ""
}
  • ExtractionTable: extracts from data
 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 
        {
        "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.

Back to top