OBJECT
ProcessorFunction
A managed Function used in either a ProcessorNode or a CrossTenantSendingNode.
link GraphQL Schema definition
- type ProcessorFunction implements Function {
- # The MessageType passed in to the Function.
- MessageType! :
- # A Python code string that contains a single top-level function definition.
- # This function is used as a template when creating custom processing in
- # ProcessorNodes
- # that use this MessageType. This function must have the signature
- # (*, context, message, source, **kwargs) and return None, a string or a list of
- # strings.
- String! :
- # When and who created.
- AtBy! :
- # A human-readable description.
- String! :
- # True if this is used by other resources.
- Boolean! :
- # When and who modified.
- AtBy! :
- # The name.
- String! :
- # README in MarkDown format.
- String :
- # The list of Python requirements, in pip format.
- String!] : [
- # The MessageType returned by the Function.
- MessageType :
- # True if this is an EchoStream system resource.
- Boolean :
- # The Tenant.
- Tenant :
- # Deletes this.
- Boolean! :
- # Lists the changes.
- #
- # Arguments
- # endDateTime: The end date/time (inclusive) to list changes for
- # in ISO8601 format. Defaults to now.
- # exclusiveStartKey: The lastEvaluatedKey from a previous
- # ChangeResult. Used when paginating.
- # limit: Used for limiting the number of results when paginating.
- # Defaults to "all".
- # sortAscending: True for ascending results, False for descending
- # result. Defaults to True.
- # startDateTime: The start date/time (inclusive) to list changes
- # for in ISO8601 format. Defaults to the beginning of time.
- (
- AWSDateTime, :
- AWSJSON, :
- Int, :
- Boolean, :
- AWSDateTime :
- ): ChangeResult!
- # Updates the Function. Note that all Nodes that use this Function may also be
- # updated - see blow.
- #
- # Arguments
- # code: A Python code string that contains a single top-level
- # function definition.
- # This function is used as a template when creating custom processing in
- # ProcessorNodes
- # that use this MessageType. This function must have the signature
- # (*, context, message, source, **kwargs) and return None, a string or a list of
- # strings.
- # description: The description. Null is ignored.
- # readme: The README. Must be in MarkDown format. Null removes
- # the readme.
- # The README in MarkDown format.
- # requirements: The requirements. Each element must be in pip
- # requirement format. Null or an empty list removes all requirements.
- (
- String, :
- String, :
- String, :
- String!] : [
- ): ProcessorFunction!
- # Validates the supplied code against the supplied message.
- #
- # Arguments
- # code: The code to validate.
- # message: The message to use for validation.
- # loggingLevel: The loggingLevel to use during the validation.
- # Defaults to INFO.
- # source: The source "node" of the test message. Defaults to
- # "Validation".
- (
- String!, :
- String!, :
- LogLevel, :
- String :
- ): ValidationResult!
- }
link Require by
- CrossTenantSendingNodeAllows for sending messages to another Tenant.
- EchoA union of all EchoStream object types
- MutationRoot Mutation
- ProcessorFunctionA managed Function used in either a ProcessorNode or a CrossTenantSendingNode.
- ProcessorNodeProcessorNodes allow for almost any processing of messages, including transformation, augmentation, generation, combination and splitting.