from cognite.client.data_classes import TransformationWrite, TransformationDestination
from cognite.client.data_classes.transformations.common import ViewInfo, EdgeType, DataModelInfo
transformations = [
TransformationWrite(
external_id="transformation1",
name="transformation1",
ignore_null_fields=False,
destination=TransformationDestination.assets()
),
TransformationWrite(
external_id="transformation2",
name="transformation2",
ignore_null_fields=False,
destination=TransformationDestination.raw("myDatabase", "myTable")
),
TransformationWrite(
external_id="transformation3",
name="transformation3",
ignore_null_fields=False,
view = ViewInfo(space="TypeSpace", external_id="TypeExtId", version="version"),
destination=TransformationDestination.nodes(view, "InstanceSpace")
),
TransformationWrite(
external_id="transformation4",
name="transformation4",
ignore_null_fields=False,
view = ViewInfo(space="TypeSpace", external_id="TypeExtId", version="version"),
destination=TransformationDestination.edges(view, "InstanceSpace")
),
TransformationWrite(
external_id="transformation5",
name="transformation5",
ignore_null_fields=False,
edge_type = EdgeType(space="TypeSpace", external_id="TypeExtId"),
destination=TransformationDestination.edges(edge_type,"InstanceSpace")
),
TransformationWrite(
external_id="transformation6",
name="transformation6",
ignore_null_fields=False,
data_model = DataModelInfo(space="modelSpace", external_id="modelExternalId",version="modelVersion",destination_type="viewExternalId"),
destination=TransformationDestination.instances(data_model,"InstanceSpace")
),
TransformationWrite(
external_id="transformation7",
name="transformation7",
ignore_null_fields=False,
data_model = DataModelInfo(space="modelSpace", external_id="modelExternalId",version="modelVersion",destination_type="viewExternalId", destination_relationship_from_type="connectionPropertyName"),
destination=TransformationDestination.instances(data_model,"InstanceSpace")
),
]
res = client.transformations.create(transformations){
"items": [
{
"id": 123,
"name": "<string>",
"query": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"isPublic": true,
"createdTime": 123,
"lastUpdatedTime": 123,
"owner": "<string>",
"ownerIsCurrentUser": true,
"hasSourceOidcCredentials": true,
"hasDestinationOidcCredentials": true,
"externalId": "my.known.id",
"ignoreNullFields": true,
"blocked": {
"reason": "<string>",
"createdTime": 123
},
"sourceSession": {
"clientId": "<string>",
"sessionId": 123,
"projectName": "<string>"
},
"destinationSession": {
"clientId": "<string>",
"sessionId": 123,
"projectName": "<string>"
},
"lastFinishedJob": {
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
},
"runningJob": {
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
},
"schedule": {
"id": 123,
"externalId": "<string>",
"createdTime": 123,
"lastUpdatedTime": 123,
"interval": "0 0 * * *",
"isPaused": true
},
"dataSetId": 123,
"tags": [
"<string>"
]
}
]
}Required capabilities:
transformationsAcl:WRITE
Create a maximum of 1000 transformations per request.
from cognite.client.data_classes import TransformationWrite, TransformationDestination
from cognite.client.data_classes.transformations.common import ViewInfo, EdgeType, DataModelInfo
transformations = [
TransformationWrite(
external_id="transformation1",
name="transformation1",
ignore_null_fields=False,
destination=TransformationDestination.assets()
),
TransformationWrite(
external_id="transformation2",
name="transformation2",
ignore_null_fields=False,
destination=TransformationDestination.raw("myDatabase", "myTable")
),
TransformationWrite(
external_id="transformation3",
name="transformation3",
ignore_null_fields=False,
view = ViewInfo(space="TypeSpace", external_id="TypeExtId", version="version"),
destination=TransformationDestination.nodes(view, "InstanceSpace")
),
TransformationWrite(
external_id="transformation4",
name="transformation4",
ignore_null_fields=False,
view = ViewInfo(space="TypeSpace", external_id="TypeExtId", version="version"),
destination=TransformationDestination.edges(view, "InstanceSpace")
),
TransformationWrite(
external_id="transformation5",
name="transformation5",
ignore_null_fields=False,
edge_type = EdgeType(space="TypeSpace", external_id="TypeExtId"),
destination=TransformationDestination.edges(edge_type,"InstanceSpace")
),
TransformationWrite(
external_id="transformation6",
name="transformation6",
ignore_null_fields=False,
data_model = DataModelInfo(space="modelSpace", external_id="modelExternalId",version="modelVersion",destination_type="viewExternalId"),
destination=TransformationDestination.instances(data_model,"InstanceSpace")
),
TransformationWrite(
external_id="transformation7",
name="transformation7",
ignore_null_fields=False,
data_model = DataModelInfo(space="modelSpace", external_id="modelExternalId",version="modelVersion",destination_type="viewExternalId", destination_relationship_from_type="connectionPropertyName"),
destination=TransformationDestination.instances(data_model,"InstanceSpace")
),
]
res = client.transformations.create(transformations){
"items": [
{
"id": 123,
"name": "<string>",
"query": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"isPublic": true,
"createdTime": 123,
"lastUpdatedTime": 123,
"owner": "<string>",
"ownerIsCurrentUser": true,
"hasSourceOidcCredentials": true,
"hasDestinationOidcCredentials": true,
"externalId": "my.known.id",
"ignoreNullFields": true,
"blocked": {
"reason": "<string>",
"createdTime": 123
},
"sourceSession": {
"clientId": "<string>",
"sessionId": 123,
"projectName": "<string>"
},
"destinationSession": {
"clientId": "<string>",
"sessionId": 123,
"projectName": "<string>"
},
"lastFinishedJob": {
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
},
"runningJob": {
"id": 123,
"uuid": "<string>",
"transformationId": 123,
"transformationExternalId": "<string>",
"sourceProject": "<string>",
"destinationProject": "<string>",
"destination": {
"type": "assets"
},
"conflictMode": "abort",
"query": "<string>",
"createdTime": 123,
"ignoreNullFields": true,
"status": "Completed",
"startedTime": 123,
"finishedTime": 123,
"lastSeenTime": 123,
"error": "<string>"
},
"schedule": {
"id": 123,
"externalId": "<string>",
"createdTime": 123,
"lastUpdatedTime": 123,
"interval": "0 0 * * *",
"isPaused": true
},
"dataSetId": 123,
"tags": [
"<string>"
]
}
]
}Access token issued by the CDF project's configured identity provider. Access token must be an OpenID Connect token, and the project must be configured to accept OpenID Connect tokens. Use a header key of 'Authorization' with a value of 'Bearer $accesstoken'. The token can be obtained through any flow supported by the identity provider.
1000Show child attributes
Response with list of transformations.
Array of objects (Transformation).
Show child attributes
Was this page helpful?