curl --request POST \
--url https://api.streamkap.com/transforms/full-process \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"transform": "fan_out",
"config": {
"transforms.name": "<string>",
"transforms.input.topic.pattern": "<string>",
"transforms.output.topic.pattern": "<string>",
"transforms.input.serialization.format": "Any",
"transforms.output.serialization.format": "Any",
"transforms.language": "<string>",
"transforms.input.job.parallelism": 5
},
"implementation": {
"language": "PYTHON",
"value_transform": "<string>",
"key_transform": "<string>",
"topic_transform": "<string>",
"unit_test": {
"test_name": "<string>",
"input__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"output__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"result__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"is_success": true,
"html_diff": "<string>",
"text_diff": "<string>"
}
},
"created_from": "api"
}
'{
"id": "<string>",
"name": "<string>",
"sub_id": "<string>",
"tenant_id": "<string>",
"transform_type": "fan_out",
"config": {
"transforms.name": "<string>",
"transforms.input.topic.pattern": "<string>",
"transforms.output.topic.pattern": "<string>",
"transforms.input.serialization.format": "Any",
"transforms.output.serialization.format": "Any",
"transforms.language": "<string>",
"transforms.input.job.parallelism": 5
},
"service_id": "<string>",
"start_time": "<string>",
"job_name": "<string>",
"topic_ids": "<string>",
"implementation": {
"language": "PYTHON",
"value_transform": "<string>",
"key_transform": "<string>",
"topic_transform": "<string>",
"unit_test": {
"test_name": "<string>",
"input__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"output__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"result__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"is_success": true,
"html_diff": "<string>",
"text_diff": "<string>"
}
},
"metrics": {
"tasks": 123,
"latency": 123,
"status": "<string>",
"duration": 123,
"start_time": 123,
"end_time": "<string>"
},
"live_version": "<string>",
"preview_version": "<string>",
"version": 1,
"updated_timestamp": "2023-11-07T05:31:56Z",
"implementation_updated_timestamp": "2023-11-07T05:31:56Z"
}curl --request POST \
--url https://api.streamkap.com/transforms/full-process \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"transform": "fan_out",
"config": {
"transforms.name": "<string>",
"transforms.input.topic.pattern": "<string>",
"transforms.output.topic.pattern": "<string>",
"transforms.input.serialization.format": "Any",
"transforms.output.serialization.format": "Any",
"transforms.language": "<string>",
"transforms.input.job.parallelism": 5
},
"implementation": {
"language": "PYTHON",
"value_transform": "<string>",
"key_transform": "<string>",
"topic_transform": "<string>",
"unit_test": {
"test_name": "<string>",
"input__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"output__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"result__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"is_success": true,
"html_diff": "<string>",
"text_diff": "<string>"
}
},
"created_from": "api"
}
'{
"id": "<string>",
"name": "<string>",
"sub_id": "<string>",
"tenant_id": "<string>",
"transform_type": "fan_out",
"config": {
"transforms.name": "<string>",
"transforms.input.topic.pattern": "<string>",
"transforms.output.topic.pattern": "<string>",
"transforms.input.serialization.format": "Any",
"transforms.output.serialization.format": "Any",
"transforms.language": "<string>",
"transforms.input.job.parallelism": 5
},
"service_id": "<string>",
"start_time": "<string>",
"job_name": "<string>",
"topic_ids": "<string>",
"implementation": {
"language": "PYTHON",
"value_transform": "<string>",
"key_transform": "<string>",
"topic_transform": "<string>",
"unit_test": {
"test_name": "<string>",
"input__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"output__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"result__json": [
{
"topic": "<string>",
"value": {},
"key": {},
"timestamp": "2023-11-07T05:31:56Z"
}
],
"is_success": true,
"html_diff": "<string>",
"text_diff": "<string>"
}
},
"metrics": {
"tasks": 123,
"latency": 123,
"status": "<string>",
"duration": 123,
"start_time": 123,
"end_time": "<string>"
},
"live_version": "<string>",
"preview_version": "<string>",
"version": 1,
"updated_timestamp": "2023-11-07T05:31:56Z",
"implementation_updated_timestamp": "2023-11-07T05:31:56Z"
}Bearer authentication header of the form Bearer <token>, where <token> is your auth token.
fan_out, sql_join, enrich, enrich_async, map_filter, toast_handling, un_nesting Show child attributes
Any, Json, Avro Any, Json, Avro Show child attributes
PYTHON, JAVASCRIPT, SQL Show child attributes
terraform, web, api Successful Response
Basic transform details.
fan_out, sql_join, enrich, enrich_async, map_filter, toast_handling, un_nesting Show child attributes
Any, Json, Avro Any, Json, Avro Show child attributes
PYTHON, JAVASCRIPT, SQL Show child attributes
Was this page helpful?