我正在尝试使用 terraform 创建一个 Kinesis Firehose,并使用我收到的 JSON 中的两个分区查询进行动态分区,我的处理配置如下所示
processing_configuration {
enabled = true
processors {
type = "RecordDeAggregation"
parameters {
parameter_name = "SubRecordType"
parameter_value = "JSON"
}
}
processors {
type = "MetadataExtraction"
parameters {
parameter_name = "JsonParsingEngine"
parameter_value = "JQ-1.6"
}
parameters {
parameter_name = "MetadataExtractionQuery"
parameter_value = "{transaction_id:.transaction_id}"
}
parameters {
parameter_name = "MetadataExtractionQuery"
parameter_value = "{stage:.stage}"
}
}
}
Run Code Online (Sandbox Code Playgroud)
我还尝试为新的 ExtractionQuery 创建一个 appart 处理器,它看起来像这样
processing_configuration {
enabled = true
processors {
type = "RecordDeAggregation"
parameters {
parameter_name …Run Code Online (Sandbox Code Playgroud)