Data Transfer API, REST: Transfer.Update
- HTTP request
- Path parameters
- Body parameters
- Runtime
- YcRuntime
- ShardingUploadParams
- Transformation
- Transformer
- MaskFieldTransformer
- TablesFilter
- MaskFunction
- MaskFunctionHash
- FilterColumnsTransformer
- ColumnsFilter
- RenameTablesTransformer
- RenameTable
- Table
- ReplacePrimaryKeyTransformer
- ToStringTransformer
- SharderTransformer
- TableSplitterTransformer
- FilterRowsTransformer
- Response
- Status
HTTP request
PATCH https://datatransfer.api.cloud.yandex.net/v1/transfer/{transferId}
Path parameters
Field |
Description |
transferId |
string Required field. Identifier of the transfer to be updated. |
Body parameters
{
"description": "string",
"runtime": {
// Includes only one of the fields `ycRuntime`
"ycRuntime": {
"jobCount": "string",
"uploadShardParams": {
"jobCount": "string",
"processCount": "string"
}
}
// end of the list of possible fields
},
"name": "string",
"updateMask": "object",
"labels": "object",
"transformation": {
"transformers": [
{
// Includes only one of the fields `maskField`, `filterColumns`, `renameTables`, `replacePrimaryKey`, `convertToString`, `sharderTransformer`, `tableSplitterTransformer`, `filterRows`
"maskField": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"columns": [
"string"
],
"function": {
// Includes only one of the fields `maskFunctionHash`
"maskFunctionHash": {
"userDefinedSalt": "string"
}
// end of the list of possible fields
}
},
"filterColumns": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"columns": {
"includeColumns": [
"string"
],
"excludeColumns": [
"string"
]
}
},
"renameTables": {
"renameTables": [
{
"originalName": {
"nameSpace": "string",
"name": "string"
},
"newName": {
"nameSpace": "string",
"name": "string"
}
}
]
},
"replacePrimaryKey": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"keys": [
"string"
]
},
"convertToString": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"columns": {
"includeColumns": [
"string"
],
"excludeColumns": [
"string"
]
}
},
"sharderTransformer": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"columns": {
"includeColumns": [
"string"
],
"excludeColumns": [
"string"
]
},
"shardsCount": "string"
},
"tableSplitterTransformer": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"columns": [
"string"
],
"splitter": "string"
},
"filterRows": {
"tables": {
"includeTables": [
"string"
],
"excludeTables": [
"string"
]
},
"filter": "string",
"filters": [
"string"
]
}
// end of the list of possible fields
}
]
}
}
Field |
Description |
description |
string The new description for the transfer. |
runtime |
|
name |
string The new transfer name. Must be unique within the folder. |
updateMask |
object (field-mask) A comma-separated names off ALL fields to be updated. If |
labels |
object (map<string, string>) |
transformation |
Runtime
Field |
Description |
ycRuntime |
Includes only one of the fields |
YcRuntime
Field |
Description |
jobCount |
string (int64) |
uploadShardParams |
ShardingUploadParams
Field |
Description |
jobCount |
string (int64) |
processCount |
string (int64) |
Transformation
Transformation is converting data using special transformer functions.
These functions are executed on a data stream, applied to each data change item,
and transform them.
A transformer can be run at both the metadata and data levels.
Data can only be transformed if the source and target are of different types.
Field |
Description |
transformers[] |
Transformers are set as a list. |
Transformer
Some transformers may have limitations and only apply to some source-target
pairs.
Field |
Description |
maskField |
Includes only one of the fields |
filterColumns |
Includes only one of the fields |
renameTables |
Includes only one of the fields |
replacePrimaryKey |
Includes only one of the fields |
convertToString |
Includes only one of the fields |
sharderTransformer |
Includes only one of the fields |
tableSplitterTransformer |
Includes only one of the fields |
filterRows |
Includes only one of the fields |
MaskFieldTransformer
Mask field transformer allows you to hash data
Field |
Description |
tables |
List of included and excluded tables |
columns[] |
string Specify the name of the column for data masking (a regular expression). |
function |
Mask function |
TablesFilter
Filter tables using lists of included and excluded tables.
Field |
Description |
includeTables[] |
string List of tables that will be included to transfer |
excludeTables[] |
string List of tables that will be excluded to transfer |
MaskFunction
Mask function
Field |
Description |
maskFunctionHash |
Hash mask function Includes only one of the fields |
MaskFunctionHash
Hash data using HMAC
Field |
Description |
userDefinedSalt |
string This string will be used in the HMAC(sha256, salt) function applied to the |
FilterColumnsTransformer
Set up a list of table columns to transfer
Field |
Description |
tables |
List of the tables to filter using lists of included and excluded tables. |
columns |
List of the columns to transfer to the target tables using lists of included and |
ColumnsFilter
Filter columns using lists of included and excluded columns.
Field |
Description |
includeColumns[] |
string List of columns that will be included to transfer |
excludeColumns[] |
string List of columns that will be excluded to transfer |
RenameTablesTransformer
Set rules for renaming tables by specifying the current names of the tables in
the source and new names for these tables in the target.
Field |
Description |
renameTables[] |
List of renaming rules |
RenameTable
Specify rule for renaming table
Field |
Description |
originalName |
Specify the current names of the table in the source |
newName |
Specify the new names for this table in the target |
Table
Field |
Description |
nameSpace |
string |
name |
string |
ReplacePrimaryKeyTransformer
Override primary keys
Field |
Description |
tables |
List of included and excluded tables |
keys[] |
string List of columns to be used as primary keys |
ToStringTransformer
Convert column values to strings
The values will be converted depending on the source type
Conversion rules are described here:
https://cloud.yandex.com/en/docs/data-transfer/concepts/data-transformation#convert-to-string
Field |
Description |
tables |
List of included and excluded tables |
columns |
List of included and excluded columns |
SharderTransformer
Set the number of shards for particular tables and a list of columns whose
values will be used for calculating a hash to determine a shard.
Field |
Description |
tables |
List of included and excluded tables |
columns |
List of included and excluded columns |
shardsCount |
string (int64) Number of shards |
TableSplitterTransformer
A transfer splits the X table into multiple tables (X_1, X_2, ..., X_n) based on
data.
If a row was located in the X table before it was split, it is now in the X_i
table,
where i is determined by the column list and split string parameters.
Example:
If the column list has two columns, month of birth and gender, specified and the
split string states @,
information about an employee whose name is John and who was born on February
11, 1984,
from the Employees table will get to a new table named Employees@February@male.
Field |
Description |
tables |
List of included and excluded tables |
columns[] |
string Specify the columns in the tables to be partitioned. |
splitter |
string Specify the split string to be used for merging components in a new table name. |
FilterRowsTransformer
This filter only applies to transfers with queues (Logbroker or Apache Kafka®)
as a data source.
When running a transfer, only the strings meeting the specified criteria remain
in a changefeed.
Field |
Description |
tables |
List of included and excluded tables. |
filter |
string Filtering criterion. This can be comparison operators for numeric, string, and |
filters[] |
string Data is transported if it satisfies at least one of filters. Consider that there |
Response
HTTP Code: 200 - OK
{
"id": "string",
"description": "string",
"createdAt": "string",
"createdBy": "string",
"modifiedAt": "string",
"done": "boolean",
"metadata": "object",
// Includes only one of the fields `error`, `response`
"error": {
"code": "integer",
"message": "string",
"details": [
"object"
]
},
"response": "object"
// end of the list of possible fields
}
An Operation resource. For more information, see Operation.
Field |
Description |
id |
string ID of the operation. |
description |
string Description of the operation. 0-256 characters long. |
createdAt |
string (date-time) Creation timestamp. String in RFC3339 To work with values in this field, use the APIs described in the |
createdBy |
string ID of the user or service account who initiated the operation. |
modifiedAt |
string (date-time) The time when the Operation resource was last modified. String in RFC3339 To work with values in this field, use the APIs described in the |
done |
boolean If the value is |
metadata |
object Service-specific metadata associated with the operation. |
error |
The error result of the operation in case of failure or cancellation. Includes only one of the fields The operation result. |
response |
object The normal response of the operation in case of success. Includes only one of the fields The operation result. |
Status
The error result of the operation in case of failure or cancellation.
Field |
Description |
code |
integer (int32) Error code. An enum value of google.rpc.Code |
message |
string An error message. |
details[] |
object A list of messages that carry the error details. |