FGS.DisEventMap

Element Description

The FGS.DisEventMap element is used to create Data Ingestion Service (DIS) trigger resources for FunctionGraph. DIS triggers depend on the DIS service. Based on DIS events, DIS triggers can trigger function execution. To create DIS triggers, you need to enable the DIS service and configure Identity and Access Management (IAM) agencies for accessing the DIS service.

Element Properties

**Table 1** Property Description
Property	Required	Descripiton
pollingInterval	No	Interval at which data is pulled from the stream. Type: integer Value Description: The field is optional. When the field is not configured, the default period of pulling data from the stream is 30 seconds. Default: 30 Value Constraint: The effective range is 1 to 60. Suggestion: Use the get_input function to import this field. The value can be automatically obtained on the AOS page.
batchSize	No	Maximum number of records that your function will read from the stream. Type: integer Value Description: The field is optional. When the field is not configured, the default value is 100. Default: 100 Value Constraint: The effective range is 1 to 10000. Suggestion: Use the get_input function to import this field. The value can be automatically obtained on the AOS page.
streamName	Yes	Dis stream name. Type: string Value Description: The field must be selected. The field is obtained from the created DIS stream. Suggestion: Use the get_input function to import this field. The value can be automatically obtained on the AOS page.
shardIteratorType	No	Position in the stream from which to start reading data. Type: string Value Description: The field is optional. Support "TRIM_HORIZON"and"LATEST". When the field is not configured, the default value is "TRIM_HORIZON". Default: TRIM_HORIZON Value Constraint: Valid values can only be "TRIM_HORIZON","LATEST". Suggestion: Use the get_input function to import this field. The value can be automatically obtained on the AOS page.
funcId	Yes	function urn. Type: string Value Description: The field is automatically retrieved from the refID field of type HuaweiCloud.FGS.Function element by the get_reference function. The field must be selected. Suggestion: Using the default configuration.

Relationships Between Elements

**Table 2** Relationship description
Description	Target
ContainedIn	FGS.Function

Return Value

None.

Blueprint Example

tosca_definitions_version: huaweicloud_tosca_version_1_0
inputs:
  fgsde1gr_streamName:
    description: Stream name
    label: ''
  fgsfrgxk_codeType:
    description: Type of the function code to be uploaded
    label: ''
  fgsfrgxk_name:
    description: Function name
    label: ''
  fgsfrgxk_runtime:
    description: Runtime environment of the function
    label: ''
node_templates:
  fgsde1gr:
    properties:
      funcId:
        get_reference: fgsfrgxk
      streamName:
        get_input: fgsde1gr_streamName
    requirements:
      - funcId:
          node: fgsfrgxk
    type: HuaweiCloud.FGS.DisEventMap
  fgsfrgxk:
    properties:
      code: >-
        exports.handler = function (event, context, callback) { const error =
        null; const output = `Hello message: ${JSON.stringify(event)}`;
        callback(error, output); }
      codeType:
        get_input: fgsfrgxk_codeType
      codeUrl: ''
      handler: index.handler
      memorySize: 128
      name:
        get_input: fgsfrgxk_name
      runtime:
        get_input: fgsfrgxk_runtime
      timeout: 3
      role: dis
    type: HuaweiCloud.FGS.Function

Parent topic: List of Elements

Previous topic: FGS.CtsEventMap

Next topic: FGS.DmsEventMap