GCPEvents plug-in structure

Configuring a GCPEvents event source
A PubSub event source that receives GCPEvents type events can be configured in the following way:
projectId
  • Type: string
  • Multiple filters
  • Required
  • Single predicate
The unique identifier for the GCP project you want to receive events from.
serviceFile
  • Type: string
  • Multiple filters
  • Required*
  • Single predicate
The path of the service file used for authentication.
Note: If the serviceFile value is not specified, it is taken from the local environment configuration. If it is not configured in the local environment, it needs to be specified.
subscriptionId
  • Type: string
  • Multiple filters
  • Required
  • Single predicate
The session token used for authentication.
The following is an example of a generic type event source configured to receive GCPEvents type events:
$eventsource

EVENT_SOURCE /GCP1
DESCRIPTION "GCP testing"
PLUGIN GCPEvents
TYPE PubSub
CONFIGURATION {

      "projectId": "projectIdvalue",
      "serviceFile": "/home/username/Documents/Project/example.txt",
      "subscriptionId": "subscriptionIdvalue",

         }
END
GCP event condition
GCPEvent type event conditions can be configured in job streams specifying the following required properties:
  • Name
  • Type
  • Event source
You can also specify any number of porperties that filter the events received from the event source:
Message
  • Type: string
  • Operator: EQ("=") or NE("!=")
  • Wildcard allowed
  • Single predicate
Specify the PubSub message body to enable filtering of events that either match or do not match the specified input.
Attributes
  • Type: string
  • Operator: EQ("=") or NE("!=")
  • Wildcard allowed
  • Single predicate
Specify the attributes contained in the PubSub message to enable filtering of events that either match or do not match the specified input.
messageId
  • Type: string
  • Operator: EQ("=") or NE("!=")
  • Wildcard allowed
  • Single predicate
Specify the PubSub message ID to enable filtering of events that either match or do not match the specified input.
Timestamp
  • Type: string
  • Operator: EQ("=") or NE("!=")
  • Wildcard allowed
  • Single predicate
Specify the PubSub message timestamp to enable filtering of events that either match or do not match the specified input.
orderingKey
  • Type: string
  • Operator: EQ("=") or NE("!=")
  • Wildcard allowed
  • Single predicate
Specify the PubSub message odering key to enable filtering of events that either match or do not match the specified input.
The following is an example of a job stream with two GCP event conditions:
TRIGGER MY_TRIGGER DESCRIPTION "my event trigger" TIMEOUT 1000 TRIGGER_ON_TIMEOUT CORRELATIONS A, A1
    CONDITIONS IN ORDER
    NAME attributes  TYPE plugin/GCP    SOURCE MY_EVENT_SOURCE FILTERS ATTRIBUTES = attributesvalue
    NAME timestamp   TYPE plugin/GCP    SOURCE MY_EVENT_SOURCE FILTERS TIMESTAMP = timestampvalue