Last active
March 26, 2020 18:25
-
-
Save nvolungis/56d863c7a848bd6d4bfb4b809555634c to your computer and use it in GitHub Desktop.
basic ingestion spec for flat player events
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"type": "kafka", | |
"ioConfig": { | |
"consumerProperties": { | |
"bootstrap.servers": "kafka:19092" | |
}, | |
"topic": "stats_tap.flat_player_event.proto.v0", | |
"type": "kafka", | |
"taskCount": 1, | |
"replicas": 1 | |
}, | |
"tuningConfig": { | |
"type": "kafka" | |
}, | |
"dataSchema": { | |
"dataSource": "stats_tap.flat_player_event.proto.v0", | |
"parser": { | |
"type": "protobuf", | |
"descriptor": "https://wistia-analytics-archive.s3.us-east-1.amazonaws.com/protobuf/schema.desc?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=ASIAQAZE5UZCUKCLCANK%2F20200326%2Fus-east-1%2Fs3%2Faws4_request&X-Amz-Date=20200326T171851Z&X-Amz-Expires=604800&X-Amz-SignedHeaders=host&X-Amz-Security-Token=FwoGZXIvYXdzEKn%2F%2F%2F%2F%2F%2F%2F%2F%2F%2FwEaDI%2BorB4uhCwBelinGCKEASDiTPia0acp%2Fe9AUJs7EhhsiolVWFfdR9FL2jp5rvv0LlC0U6bsJBpRJDj6JuqjPGuFmlVq0bzyKWpLIHVbqXBaH188yo%2B9HJtQIsw3KrRvZFK2TT7glvb4AvwuwTNjgk8GjYigKr%2Fl8uIJ3bdQYGumJuIo72A7uIJIFz4yrDtgGCFZcijdj%2FPzBTIpzfjgAzcAD7YCuJ1J%2Fnna%2BYoeKJUBKawZD9viGfKResrRrgOE5sPFL1o%3D&X-Amz-Signature=ffe405aa1211d4094a7f9eb1065fb5662cf31f711ff44faa0a52862c015e9b78", | |
"protoMessageType": "FlatPlayerEvent", | |
"parseSpec": { | |
"format": "json", | |
"timestampSpec": { | |
"column": "timestamp", | |
"format": "auto", | |
"missingValue": "2010-01-01T00:00:00Z" | |
}, | |
"dimensionsSpec": { | |
"dimensions": [ | |
"account_key", | |
"action.category", | |
"action.key", | |
"action.text", | |
"action.type", | |
"action.uniqueToVisitor", | |
"caption.caption_key", | |
"caption.enabled", | |
"caption.language", | |
"conversion_data.converted", | |
"conversion_data.email", | |
"conversion_data.first_name", | |
"conversion_data.last_name", | |
"conversion.co_key", | |
"conversion.co_type", | |
"conversion.converted", | |
"conversion.email", | |
"conversion.first_name", | |
"conversion.last_name", | |
"conversion.link", | |
"correlation_id", | |
"event_key", | |
"ip", | |
"isUnique", | |
"key", | |
"media_id", | |
"media_type", | |
"project_hashed_id", | |
"referrer", | |
"session_id", | |
"user_agent", | |
"utm_params.campaign", | |
"utm_params.medium", | |
"utm_params.source" | |
] | |
}, | |
"flattenSpec": { | |
"fields": [ | |
{ | |
"name": "action.category", | |
"type": "path", | |
"expr": "$.action.category" | |
}, | |
{ | |
"name": "action.key", | |
"type": "path", | |
"expr": "$.action.key" | |
}, | |
{ | |
"name": "action.text", | |
"type": "path", | |
"expr": "$.action.text" | |
}, | |
{ | |
"name": "action.time", | |
"type": "path", | |
"expr": "$.action.time" | |
}, | |
{ | |
"name": "action.type", | |
"type": "path", | |
"expr": "$.action.type" | |
}, | |
{ | |
"name": "action.uniqueToVisitor", | |
"type": "path", | |
"expr": "$.action.uniqueToVisitor" | |
}, | |
{ | |
"name": "caption.caption_key", | |
"type": "path", | |
"expr": "$.caption.caption_key" | |
}, | |
{ | |
"name": "caption.enabled", | |
"type": "path", | |
"expr": "$.caption.enabled" | |
}, | |
{ | |
"name": "caption.language", | |
"type": "path", | |
"expr": "$.caption.language" | |
}, | |
{ | |
"name": "caption.time", | |
"type": "path", | |
"expr": "$.caption.time" | |
}, | |
{ | |
"name": "conversion.co_key", | |
"type": "path", | |
"expr": "$.conversion.co_key" | |
}, | |
{ | |
"name": "conversion.co_type", | |
"type": "path", | |
"expr": "$.conversion.co_type" | |
}, | |
{ | |
"name": "conversion.converted", | |
"type": "path", | |
"expr": "$.conversion.converted" | |
}, | |
{ | |
"name": "conversion.email", | |
"type": "path", | |
"expr": "$.conversion.email" | |
}, | |
{ | |
"name": "conversion.first_name", | |
"type": "path", | |
"expr": "$.conversion.first_name" | |
}, | |
{ | |
"name": "conversion.last_name", | |
"type": "path", | |
"expr": "$.conversion.last_name" | |
}, | |
{ | |
"name": "conversion.link", | |
"type": "path", | |
"expr": "$.conversion.link" | |
}, | |
{ | |
"name": "conversion.time", | |
"type": "path", | |
"expr": "$.conversion.time" | |
}, | |
{ | |
"name": "conversion_data.converted", | |
"type": "path", | |
"expr": "$.conversion_data.converted" | |
}, | |
{ | |
"name": "conversion_data.email", | |
"type": "path", | |
"expr": "$.conversion_data.email" | |
}, | |
{ | |
"name": "conversion_data.first_name", | |
"type": "path", | |
"expr": "$.conversion_data.first_name" | |
}, | |
{ | |
"name": "conversion_data.last_name", | |
"type": "path", | |
"expr": "$.conversion_data.last_name" | |
}, | |
{ | |
"name": "utm_params.campaign", | |
"type": "path", | |
"expr": "$.utm_params.campaign" | |
}, | |
{ | |
"name": "utm_params.medium", | |
"type": "path", | |
"expr": "$.utm_params.medium" | |
}, | |
{ | |
"name": "utm_params.source", | |
"type": "path", | |
"expr": "$.utm_params.source" | |
} | |
] | |
}, | |
"granularitySpec": { | |
"type": "uniform", | |
"queryGranularity": "HOUR", | |
"segmentGranularity": "HOUR", | |
"rollup": true | |
}, | |
"metricsSpec": [ | |
{ | |
"name": "count", | |
"type": "count" | |
}, | |
{ | |
"name": "sum_action.time", | |
"type": "longSum", | |
"fieldName": "action.time" | |
}, | |
{ | |
"name": "sum_caption.time", | |
"type": "longSum", | |
"fieldName": "caption.time" | |
}, | |
{ | |
"name": "sum_conversion_type", | |
"type": "longSum", | |
"fieldName": "conversion_type" | |
}, | |
{ | |
"name": "sum_conversion.time", | |
"type": "longSum", | |
"fieldName": "conversion.time" | |
}, | |
{ | |
"name": "sum_endBucket", | |
"type": "longSum", | |
"fieldName": "endBucket" | |
}, | |
{ | |
"name": "sum_received_at", | |
"type": "longSum", | |
"fieldName": "received_at" | |
}, | |
{ | |
"name": "sum_startBucket", | |
"type": "longSum", | |
"fieldName": "startBucket" | |
}, | |
{ | |
"name": "sum_timeDelta", | |
"type": "longSum", | |
"fieldName": "timeDelta" | |
}, | |
{ | |
"name": "sum_visitor_version", | |
"type": "longSum", | |
"fieldName": "visitor_version" | |
} | |
] | |
} | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment