- 필수 기능
- 시작하기
- Glossary
- 표준 속성
- Guides
- Agent
- 통합
- 개방형텔레메트리
- 개발자
- Administrator's Guide
- API
- Datadog Mobile App
- CoScreen
- Cloudcraft
- 앱 내
- 서비스 관리
- 인프라스트럭처
- 애플리케이션 성능
- APM
- Continuous Profiler
- 스팬 시각화
- 데이터 스트림 모니터링
- 데이터 작업 모니터링
- 디지털 경험
- 소프트웨어 제공
- 보안
- AI Observability
- 로그 관리
- 관리
",t};e.buildCustomizationMenuUi=t;function n(e){let t='
",t}function s(e){let n=e.filter.currentValue||e.filter.defaultValue,t='${e.filter.label}
`,e.filter.options.forEach(s=>{let o=s.id===n;t+=``}),t+="${e.filter.label}
`,t+=`ancestors
Type: UNORDERED_LIST_STRING
annotations
Type: MAP_STRING_STRING
Provider name: annotations
Description: Optional. User-defined annotations. See https://google.aip.dev/128#annotations.
create_time
Type: TIMESTAMP
Provider name: createTime
Description: Output only. The creation time. A timestamp in RFC3339 UTC “Zulu” format, with nanosecond resolution and up to nine fractional digits. Examples: “2014-10-02T15:01:23Z” and “2014-10-02T15:01:23.045123456Z”.
crypto_key_name
Type: STRING
Provider name: cryptoKeyName
Description: Optional. Resource name of a KMS crypto key (managed by the user) used to encrypt/decrypt the event data. If not set, an internal Google-owned key will be used to encrypt messages. It must match the pattern “projects/{project}/locations/{location}/keyRings/{keyring}/cryptoKeys/{key}”.
destinations
Type: UNORDERED_LIST_STRUCT
Provider name: destinations
Description: Required. List of destinations to which messages will be forwarded. Currently, exactly one destination is supported per Pipeline.
authentication_config
STRUCT
authenticationConfig
google_oidc
STRUCT
googleOidc
audience
STRING
audience
service_account
STRING
serviceAccount
oauth_token
STRUCT
oauthToken
Authorization
header in the HTTP request. This type of authorization should generally only be used when calling Google APIs hosted on *.googleapis.com.scope
STRING
scope
service_account
STRING
serviceAccount
http_endpoint
STRUCT
httpEndpoint
message_binding_template
STRING
messageBindingTemplate
data
and datacontenttype
field on the message are mapped to HTTP request headers with a prefix of ce-
. To construct the HTTP request payload and the value of the content-type HTTP header, the payload format is defined as follows: 1) Use the output_payload_format_type on the Pipeline.Destination if it is set, else: 2) Use the input_payload_format_type on the Pipeline if it is set, else: 3) Treat the payload as opaque binary data. The data
field of the message is converted to the payload format or left as-is for case 3) and then attached as the payload of the HTTP request. The content-type
header on the HTTP request is set to the payload format type or left empty for case 3). However, if a mediation has updated the datacontenttype
field on the message so that it is not the same as the payload format type but it is still a prefix of the payload format type, then the content-type
header on the HTTP request is set to this datacontenttype
value. For example, if the datacontenttype
is “application/json” and the payload format type is “application/json; charset=utf-8”, then the content-type
header on the HTTP request is set to “application/json; charset=utf-8”. If a non-empty binding expression is specified then this expression is used to modify the default CloudEvent HTTP Protocol Binding Binary Content representation. The result of the CEL expression must be a map of key/value pairs which is used as follows: - If a map named headers
exists on the result of the expression, then its key/value pairs are directly mapped to the HTTP request headers. The headers values are constructed from the corresponding value type’s canonical representation. If the headers
field doesn’t exist then the resulting HTTP request will be the headers of the CloudEvent HTTP Binding Binary Content Mode representation of the final message. Note: If the specified binding expression, has updated the datacontenttype
field on the message so that it is not the same as the payload format type but it is still a prefix of the payload format type, then the content-type
header in the headers
map is set to this datacontenttype
value. - If a field named body
exists on the result of the expression then its value is directly mapped to the body of the request. If the value of the body
field is of type bytes or string then it is used for the HTTP request body as-is, with no conversion. If the body field is of any other type then it is converted to a JSON string. If the body field does not exist then the resulting payload of the HTTP request will be data value of the CloudEvent HTTP Binding Binary Content Mode representation of the final message as described earlier. - Any other fields in the resulting expression will be ignored. The CEL expression may access the incoming CloudEvent message in its definition, as follows: - The data
field of the incoming CloudEvent message can be accessed using the message.data
value. Subfields of message.data
may also be accessed if an input_payload_format has been specified on the Pipeline. - Each attribute of the incoming CloudEvent message can be accessed using the message.
value, where is replaced with the name of the attribute. - Existing headers can be accessed in the CEL expression using the headers
variable. The headers
variable defines a map of key/value pairs corresponding to the HTTP headers of the CloudEvent HTTP Binding Binary Content Mode representation of the final message as described earlier. For example, the following CEL expression can be used to construct an HTTP request by adding an additional header to the HTTP headers of the CloudEvent HTTP Binding Binary Content Mode representation of the final message and by overwriting the body of the request: { "headers": headers.merge({"new-header-key": "new-header-value"}), "body": "new-body" }
- The default binding for the message payload can be accessed using the body
variable. It conatins a string representation of the message payload in the format specified by the output_payload_format
field. If the input_payload_format
field is not set, the body
variable contains the same message payload bytes that were published. Additionally, the following CEL extension functions are provided for use in this CEL expression: - toBase64Url: map.toBase64Url() -> string - Converts a CelValue to a base64url encoded string - toJsonString: map.toJsonString() -> string - Converts a CelValue to a JSON string - 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. - For example: { “a”: 1, “b”: { “c”: 2, “d”: 3 } “e”: [4, 5] } .denormalize() -> { “a”: 1, “b.c”: 2, “b.d”: 3, “e.0”: 4, “e.1”: 5 } - setField: map.setField(key, value) -> message - Sets the field of the message with the given key to the given value. - If the field is not present it will be added. - If the field is present it will be overwritten. - The key can be a dot separated path to set a field in a nested message. - Key must be of type string. - Value may be any valid type. - removeFields: map.removeFields([key1, key2, …]) -> message - Removes the fields of the map with the given keys. - The keys can be a dot separated path to remove a field in a nested message. - If a key is not found it will be ignored. - Keys must be of type string. - toMap: [map1, map2, …].toMap() -> map - Converts a CEL list of CEL maps to a single CEL map - toCloudEventJsonWithPayloadFormat: message.toCloudEventJsonWithPayloadFormat() -> map - Converts a message to the corresponding structure of JSON format for CloudEvents. - It converts data
to destination payload format specified in output_payload_format
. If output_payload_format
is not set, the data will remain unchanged. - It also sets the corresponding datacontenttype of the CloudEvent, as indicated by output_payload_format
. If no output_payload_format
is set it will use the value of the “datacontenttype” attribute on the CloudEvent if present, else remove “datacontenttype” attribute. - 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. The Pipeline expects that the message it receives adheres to the standard CloudEvent format. If it doesn’t then the outgoing message request may fail with a persistent error.uri
STRING
uri
https://svc.us-central1.p.local:8080/route
. Only the HTTPS protocol is supported.message_bus
STRING
messageBus
projects/{project}/locations/{location}/messageBuses/{message_bus}
network_config
STRUCT
networkConfig
network_attachment
STRING
networkAttachment
projects/{PROJECT_ID}/regions/{REGION}/networkAttachments/{NETWORK_ATTACHMENT_NAME}
output_payload_format
STRUCT
outputPayloadFormat
avro
Type: STRUCT
Provider name: avro
Description: Optional. Avro format.
schema_definition
STRING
schemaDefinition
json
Type: STRUCT
Provider name: json
Description: Optional. JSON format.
protobuf
Type: STRUCT
Provider name: protobuf
Description: Optional. Protobuf format.
schema_definition
STRING
schemaDefinition
topic
STRING
topic
projects/{project}/locations/{location}/topics/{topic}
workflow
STRING
workflow
projects/{project}/locations/{location}/workflows/{workflow}
etag
Type: STRING
Provider name: etag
Description: Output only. This checksum is computed by the server based on the value of other fields, and might be sent only on create requests to ensure that the client has an up-to-date value before proceeding.
gcp_display_name
Type: STRING
Provider name: displayName
Description: Optional. Display name of resource.
input_payload_format
Type: STRUCT
Provider name: inputPayloadFormat
Description: Optional. The payload format expected for the messages received by the Pipeline. If input_payload_format is set then any messages not matching this format will be treated as persistent errors. If input_payload_format is not set, then the message data will be treated as an opaque binary and no output format can be set on the Pipeline through the Pipeline.Destination.output_payload_format field. Any Mediations on the Pipeline that involve access to the data field will fail as persistent errors.
avro
Type: STRUCT
Provider name: avro
Description: Optional. Avro format.
schema_definition
STRING
schemaDefinition
json
Type: STRUCT
Provider name: json
Description: Optional. JSON format.
protobuf
Type: STRUCT
Provider name: protobuf
Description: Optional. Protobuf format.
schema_definition
STRING
schemaDefinition
labels
Type: UNORDERED_LIST_STRING
logging_config
Type: STRUCT
Provider name: loggingConfig
Description: Optional. Config to control Platform Logging for Pipelines.
log_severity
STRING
logSeverity
LOG_SEVERITY_UNSPECIFIED
- Log severity is not specified. This value is treated the same as NONE, but is used to distinguish between no update and update to NONE in update_masks.NONE
- Default value at resource creation, presence of this value must be treated as no logging/disable logging.DEBUG
- Debug or trace level logging.INFO
- Routine information, such as ongoing status or performance.NOTICE
- Normal but significant events, such as start up, shut down, or a configuration change.WARNING
- Warning events might cause problems.ERROR
- Error events are likely to cause problems.CRITICAL
- Critical events cause more severe problems or outages.ALERT
- A person must take action immediately.EMERGENCY
- One or more systems are unusable.mediations
Type: UNORDERED_LIST_STRUCT
Provider name: mediations
Description: Optional. List of mediation operations to be performed on the message. Currently, only one Transformation operation is allowed in each Pipeline.
transformation
STRUCT
transformation
transformation_template
STRING
transformationTemplate
name
Type: STRING
Provider name: name
Description: Identifier. The resource name of the Pipeline. Must be unique within the location of the project and must be in projects/{project}/locations/{location}/pipelines/{pipeline}
format.
organization_id
Type: STRING
parent
Type: STRING
project_id
Type: STRING
project_number
Type: STRING
resource_name
Type: STRING
retry_policy
Type: STRUCT
Provider name: retryPolicy
Description: Optional. The retry policy to use in the pipeline.
max_attempts
INT32
maxAttempts
max_retry_delay
STRING
maxRetryDelay
min_retry_delay
STRING
minRetryDelay
satisfies_pzs
Type: BOOLEAN
Provider name: satisfiesPzs
Description: Output only. Whether or not this Pipeline satisfies the requirements of physical zone separation
tags
Type: UNORDERED_LIST_STRING
uid
Type: STRING
Provider name: uid
Description: Output only. Server-assigned unique identifier for the Pipeline. The value is a UUID4 string and guaranteed to remain unchanged until the resource is deleted.
update_time
Type: TIMESTAMP
Provider name: updateTime
Description: Output only. The last-modified time. A timestamp in RFC3339 UTC “Zulu” format, with nanosecond resolution and up to nine fractional digits. Examples: “2014-10-02T15:01:23Z” and “2014-10-02T15:01:23.045123456Z”.