Optional. The CEL expression template to apply to transform messages.
The following CEL extension functions are provided for
use in this CEL expression:
merge:
map1.merge(map2) -> map3
Merges the passed CEL map with the existing CEL map the
function is applied to.
If the same key exists in both maps, if the key's value is type
map both maps are merged else the value from the passed map is
used.
denormalize:
map.denormalize() -> map
Denormalizes a CEL map such that every value of type map or key
in the map is expanded to return a single level map.
The resulting keys are "." separated indices of the map keys.
Converts a message to the corresponding structure of JSON
format for CloudEvents
This function applies toDestinationPayloadFormat() to the
message data. It also sets the corresponding datacontenttype of
the CloudEvent, as indicated by
Pipeline.Destination.output_payload_format. If no
output_payload_format is set it will use the existing
datacontenttype on the CloudEvent if present, else leave
datacontenttype absent.
This function expects that the content of the message will
adhere to the standard CloudEvent format. If it doesn’t then this
function will fail.
The result is a CEL map that corresponds to the JSON
representation of the CloudEvent. To convert that data to a JSON
string it can be chained with the toJsonString function.
Optional. The CEL expression template to apply to transform messages.
The following CEL extension functions are provided for
use in this CEL expression:
merge:
map1.merge(map2) -> map3
Merges the passed CEL map with the existing CEL map the
function is applied to.
If the same key exists in both maps, if the key's value is type
map both maps are merged else the value from the passed map is
used.
denormalize:
map.denormalize() -> map
Denormalizes a CEL map such that every value of type map or key
in the map is expanded to return a single level map.
The resulting keys are "." separated indices of the map keys.
Converts a message to the corresponding structure of JSON
format for CloudEvents
This function applies toDestinationPayloadFormat() to the
message data. It also sets the corresponding datacontenttype of
the CloudEvent, as indicated by
Pipeline.Destination.output_payload_format. If no
output_payload_format is set it will use the existing
datacontenttype on the CloudEvent if present, else leave
datacontenttype absent.
This function expects that the content of the message will
adhere to the standard CloudEvent format. If it doesn’t then this
function will fail.
The result is a CEL map that corresponds to the JSON
representation of the CloudEvent. To convert that data to a JSON
string it can be chained with the toJsonString function.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-12-05 UTC."],[],[]]
