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.