Connectors task

TheConnectors task lets you quickly and securely connect to the various Google Cloud services and other business applications from your integration using the out-of-the-box connectors available inIntegration Connectors.

For the list of all the supported connectors for Application Integration, seeConnector reference.Important: Integration Connectors is a billable component of Google Cloud. For information about the costs and charges of using Integration Connectors, seeIntegration Connectors pricing.

Before you begin

  • Make sure that you have the Connectors Admin (roles/connectors.admin) IAM role granted on your Google Cloud project. For information about granting roles, seeManage access.
  • Learn about the general concepts ofIntegration Connectors.
  • To connect to Google Cloud services and other business applications using a connector, ensure that you haveattached a user-managed service account to your integration. If your integration does not have user-managed service account configured, then by default thedefault service account (service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com) is used for authentication.
  • Ensure that your service account has the required IAM role. For information about granting roles to a service account, seeManage access to service accounts.

Add a Connectors task

To add the Connectors task to your integration, do the following:

  1. In the Google Cloud console, go to theApplication Integration page.

    Go to Application Integration

  2. In the navigation menu, clickIntegrations.

    TheIntegrations page appears listing all the integrations available in the Google Cloud project.

  3. Select an existing integration or clickCreate integration to create a new one.

    If you are creating a new integration:

    1. Enter a name and description in theCreate Integration pane.
    2. Select a region for the integration.Note: TheRegions dropdown only lists the regions provisioned in your Google Cloud project. To provision a new region, clickEnable Region. SeeEnable new region for more information.
    3. Select a service account for the integration. You can change or update the service account details of an integration any time from theIntegration summary pane in the integration toolbar.Note: The option to select a service account is displayed only if you have enabled integration governance for the selected region.
    4. ClickCreate. The newly created integration opens in theintegration editor.

  4. In theintegration editor navigation bar, clickTasks to view the list of available tasks and connectors.
  5. image showing connectors task

  6. If you want to configure a new connection, click and place theConnectors element in the integration editor. Then, clickConfigure connector to configure the connection.

    image showing connector task listingimage showing connector task listing

  7. If you have an existing connection, click theConnectors tab to view the recently created connections. You can also search for a connector, connection, or task by entering the name in theSearch field.

    image showing search capability for connectors task

  8. Click and place the configuredConnectors element in the integration editor. For information about how to configure a connector task, seeConfigure the Connectors task.

Configure the Connectors task

To configure aConnectors task, do the following:Note: Configuration details such as authentication will vary depending upon the connection type.

  1. Click theConnectors task element on the designer to view theConnectors task configuration pane.

    Optionally, click to rename the task name.

  2. ClickConfigure connector.
  3. You can either select an existing connection in the region orcreate a new connection. To configure an existing connection, complete the following steps in theConnectors Task Editor page.

    The following image shows a sample layout of theConnectors Task Editor page.image showing Configure connector task dialogimage showing Configure connector task dialog

    1. In theSelect connection section, select the region of the connection.
    2. Choose an existing connection from the list of available connections in the selected region.
    3. ClickNext.
    4. From theType list, selectEntities orActions.
      • If you selectEntities, the list of supported entities for the connection is displayed in theSet entities/actions section. Select an entity followed by theOperation that you want to perform on that entity.
      • If you selectActions, the list of supported actions for the connection is displayed in theSet entities/actions column. Select an action for the connection.
      • The supported entities and actions are based on the connector type. For the list of all the supported connectors for Application Integration, seeConnector reference. To view the supported actions and entities for a connector, see the specific connector documentation.

        If the connector supports custom SQL queries, you can select theExecute custom query option from theActions list. For information about how to add custom SQL query for your connector, seeAction: Execute custom SQL query.

      Note: Not all connection types supportEntities orActions. If a connection type doesn't support any actions or entities, the correspondingEntities andActions lists will be empty. For more about entities and actions, seeEntities, operations, and actions.
    5. ClickDone to complete the connection configuration and close the pane.

Configure task input and output variables

TheConnectors task configuration pane displaysTask Input andTask Outputvariables that are automatically generated based on theEntity and Operation orAction selected in theConfigure connector task dialog. These variables are configurable and are accessible as inputs to the current task, as outputs to subsequent tasks, or as conditionals in the current integration.

To configure theTask Input orTask Output variables, click the respective variable to open theConfigure Variable pane and perform the following steps:

  1. Enter the variable value in theDefault Value field.
  2. (Optional) SelectUse as an input to integration orUse as an output to integration.
  3. ClickSave.

For more information about the input and output parameters of theConnectors task, seeEntity operations.

Configure authentication override

To enable the connection to accept different backend authentication dynamically during runtime, ensure that in Integration Connectors, you have selected theEnable Authentication Override option for your connection.

To configure the authentication override, do the following:

  1. Click the connectors task element on the designer to view theConnectors task configuration pane.
  2. Expand theTask input section. TheEnd user credentials field is set to adynamicAuthConfig variable.

    End user credentialsEnd user credentials

    Then, do the following:

    1. Click thedynamicAuthConfig variable. TheEdit variable pane appears.

      For overriding the authentication, you must provide the authentication values when youtest the integration.

      Edit dynamic euc variableEdit dynamic euc variable

      To do so, follow these steps:

      1. From theVariable type list, selectInput to Integration.
      2. In theJSON schema options, you can verify the authentication type configured for the connection. Use this schema to override the authentication value when youtest the integration.

        Test integration for auth overrideTest integration for auth override

    Alternatively, you can pass the authentication as the HTTP header by selecting theUse HTTPS Header for Auth Config checkbox in theTask input section of theConnectors task configuration pane.

    The dynamic authentication header should be in the following JSON format:

    {"task1":{"oauth2_auth_code_flow.access_token":"token_value"},"task2":{"oauth2_auth_code_flow.userename":"username_value"}}

    In this format,taskN corresponds to the Task ID inintegrationVersion.

    Test integration by passing the authentication as the HTTP headerTest integration by passing authentication as the HTTP header

Entity operations and actions

You can perform CRUD (Create, Read, Update, Delete) operationson the entities of a connector. Each of these entity operations has a different set of input and output parameters. The following table lists the input and output parameters for the various entity operations.

Operation nameInput parametersOutput parameters
List
  • listEntitiesPageSize
  • listEntitiesPageToken
  • listEntitiesSortByColumns
  • filterClause
  • connectorOutputPayload
  • listEntitiesNextPageToken
GetentityIdconnectorOutputPayload
Note: You can use theGet operation only to fetch a single record from a table that has a primary key. Alternately, you can use theList operation with afilterClause.
CreateconnectorInputPayloadconnectorOutputPayload
Update
  • connectorInputPayload
  • entityId
  • filterClause
connectorOutputPayload
Delete
  • entityId
  • filterClause
N/A

Input parameters

The following table describes the input parameters for the various entity operations.

Parameter nameData typeDescription
entityIdString

A unique identifier of the row that you want to access.

Normally, theentityId is a primary key value of a table or a dataset. If you specify a value for theentityId and the table or dataset doesn't have a primary key column, Integration reports a runtime error and theConnectors task fails.

For example, to get a specific row from a MySQL table, theentityId is the primary key value in the table.

Note: TheentityId is not mandatory for BigQuery. This field is empty when a BigQuery table doesn't have a primary key.
connectorInputPayloadJSONThe actual data to be added or updated in an entity. The following example shows the JSON snippet of a row data to be added in a table:
{"employee_first_name": "John","employee_emailID": "test-05@test.com"}

In this example,employee_first_name andemployee_emailID are the column names with the corresponding valuesJohn andtest-05@test.com.

filterClauseStringRestricts the result of the operations based on a condition. For more information about adding a filter clause, seeAdd a filter for an operation.
listEntitiesPageSizeInteger

Specifies the number of results that should be returned in a page.

A page is a logical grouping of the records in a result set. The concept of a page is useful when you are expecting a large number of records in the result set. If the result set is large, theConnectors task might fail, as there is a limit on the data size that theConnectors task can process. By breaking down the result set into smaller chunks, you can avoid this issue.

For example, if you are expecting 1000 records in your result set, you can set thelistEntitiesPageSize to 100. So when theConnectors task runs for the first time, it returns the first 100 records, the next 100 records in the second run and so on.

Important:
  • The default page size is 25, and the maximum number of pages supported by the task is 50000.
  • Unless your table or dataset has a primary key, you must set thelistEntitiesSortByColumns parameter to uselistEntitiesPageToken.
  • Use thelistEntitiesPageSize parameter in conjunction with thelistEntitiesPageToken parameter to navigate through the pages.
listEntitiesPageTokenString

A page identifier (token) that lets you access a specific page.

You can get the value of a page token from thelistEntitiesNextPageToken output parameter. Because each page has a unique token, you have the flexibility to access any page you want in the result set. To understand the usage of this parameter, also read the description of thelistEntitiesNextPageToken output parameter.

listEntitiesSortByColumnsString arrayThe column name by which you want to sort the result set.

Note: You can sort the result set only by one column.

Output parameters

The following table describes the output parameters for the various entity operations.

Parameter nameData typeDescription
connectorOutputPayloadJSONThe output of an operation in JSON format.
listEntitiesNextPageTokenString

A system generated identifier for a page. You can think of the token as a pointer by which you can access a particular page of the result set.

If you have broken down your result set into multiple pages by setting thelistEntitiesPageSize parameter, you need a mechanism to navigate through the pages. ThelistEntitiesNextPageToken output parameter lets you do exactly that. Every time theConnectors task runs, the system generates a token for the next page and sets thelistEntitiesNextPageToken's value to the newly generated token. You can then use this token to access the next page in the result set. To access the next page, you must set thelistEntitiesPageToken input parameter to the next page's token value.

For example, consider you have set thelistEntitiesPageSize parameter to 2. When theConnectors task runs for the first time, thelistEntitiesNextPageToken is set to theChoKC2VtcGxveWVlX2lkEgkRAAAAAAAA8D8YDw== token value. You can then set thelistEntitiesPageToken input parameter to this token value to fetch the next page in the subsequent run of theConnectors task.

If your result set has a large number of pages, you can consider using theWhile Loop task to get the next page and using theData Mapping task to automatically assign page token values to thelistEntitiesPageToken input parameter after each run. MaplistEntitiesNextPageToken from the last loop iteration tolistEntitiesPageToken in theLIST Operation of the current loop iteration'sConnectors task. The While Loop task ends whenlistEntitiesNextPageToken isNULL, which implies that there are no more pages.

Filter clause for entity operations

You can restrict the records that are processed by theConnectors task using theFilter clause variable, which is available as aTask Input. For example, in the case of adelete operation, you can add a filter clause to delete records with a specificorderId.

A filter clause can be applied only for the following entity operations:

  • List
  • Delete
  • Update

When you select any of these operations, theTask Input section of theConnectors task displays theFilter clause field automatically.

Add a filter clause

To add a filter clause, perform the following steps:

  1. Click theConnectors task element on the designer to view theConnectors task configuration pane.
  2. Expand theTask Input section and click thefilterClause(Connectors) string variable.

    TheConfigure Variable dialog appears.

  3. Enter the filter clause (following theclause syntax) in theDefault Value field.
  4. ClickSave.

Filter clause syntax and examples

A filter clause has the following format:

FIELD_NAMECONDITIONFILTER_VALUE

Examples

  • OwnerId='0053t000007941XAAQ'
  • PoNumber <2345
  • OrderNumber=00110ANDStatusCode='Draft'
  • TotalAmount >2500
  • ShippingPostalCode=94043ORShippingPostalCode=77002
Important: In the filter clause, specify string values within single quotes ( ' ) or double quotes ( " ), depending on the database you are using. For example, MySQL accepts both single and double quotes, whereas BigQuery accepts only single quotes.

Use of variables in filter clause

You can't directly use an integration variable in a filter clause. If you want to use an integration variable, you must first configure aData Mapping task to create a mapping between the integration variable and the filter clause.

The following table shows a sample mapping between an integration variable and thefilterClause(Connectors) variable:

InputOutput
PRIMARY_KEY_ID = ' .CONCAT(INTEGRATION_VARIABLE) .CONCAT(')filterClause(Connectors)
WherePRIMARY_KEY_ID = ' is entered as aValue in the input row.

Action: Execute custom SQL query

To create a custom query, follow these steps:

  1. Follow the detailed instructions to add a connectors task.
  2. When youconfigure the connector task, in the type of action you want to perform, selectActions.
  3. In theAction list, selectExecute custom query, and then clickDone.

    image showing execute-custom-query-actionimage showing execute-custom-query-action

  4. Expand theTask input section, and then do the following:
    1. In theTimeout after field, enter the number of seconds to wait till the query executes.

      Default value:180 seconds.

    2. In theMaximum number of rows field, enter the maximum number of rows to be returned from the database.

      Default value:25.

    3. To update the custom query, clickEdit Custom Script. TheScript editor dialog opens.

      image showing custom-sql-queryimage showing custom-sql-query

    4. In theScript editor dialog, enter the SQL query and clickSave.

      You can use a question mark (?) in a SQL statement to represent a single parameter that must be specified in the query parameters list. For example, the following SQL query selects all rows from theEmployees table that matches the values specified for theLastName column:

      SELECT * FROM Employees where LastName=?

      Note: Data manipulation language (DML) and data definition language (DDL) statements are supported.
    5. If you've used question marks in your SQL query, you must add the parameter by clicking+ Add Parameter Name for each question mark. While executing the integration, these parameters replace the question marks (?) in the SQL query sequentially. For example, if you have added three question marks (?), then you must add three parameters in order of sequence.

      image showing add-query-paramimage showing add-query-param

      To add query parameters, do the following:

      1. From theType list, select the data type of the parameter.
      2. In theValue field, enter the value of the parameter.
      3. To add multiple parameters, click+ Add Query Parameter.
    6. TheExecute custom query action does not support array variables.

Schema refresh

All entities and actions have an associated schema. For example, an action schema includes parameter details such as parameter names and their corresponding data types. The schema (metadata) for entities and actions is fetched by the connection at runtime from your backend. If there are any updates to the schema, such updates won't be automatically reflected in your existing connections; you must manually refresh the schema. To view the updated schema in your existing connector tasks, follow these steps:
  1. In Integration Connectors, open theConnection details page of the connection, and then clickRefresh connection schema.
  2. In Application Integration, you mustreconfigure your existing connector task for the same connection.

Inline connection creation

You can use theConnectors task to directly create a new connection inIntegration Connectors.

Before you begin

Create new connection

To create a new connection from Application Integration, perform the following steps:

  1. Click theConnectors task element on the designer to view theConnectors task configuration pane.
  2. ClickConfigure connector.

    TheConnectors Task Editor page appears.

  3. Skip theRegion field.
  4. ClickConnection and select theCreate Connection option from the drop-down menu.
  5. Complete the following steps in theCreate Connection pane:Note: The following instructions are the generic steps to create a connection. While the majority of the steps remain the same for all connection types, a few additional steps or details related to authentication might vary.

    We recommend that you also view the respective connection type documentation inIntegration Connectors.

    1. In theLocation step, choose the location for the connection.
      1. ClickRegion and select a location from the drop-down list.
      2. ClickNext.
    2. In theConnection Details step, provide details about the connection:
      1. Connector: Select the type of connector that you want to create from the drop-down list. For information about the list of supported connectors, seeAll Integration Connectors.
      2. Connector version: Choose an available version of the selected Connector type from the drop-down list.
      3. Connection Name: Enter a name for the Connection instance.Note: Connection names must meet the following criteria:
        • Connection names can use letters, numbers, or hyphens.
        • Letters must be lower-case.
        • Connection names must begin with a letter and end with a letter or number.
        • Connection names cannot exceed 63 characters.
      4. (Optional) Enter aDescription for the connection instance.
      5. (Optional) CheckEnable Cloud Logging to store the log data for the connection instance.
      6. Service Account: Select a service account that has therequired roles.
      7. (Optional) ClickAdvanced settings to configure the connection node settings.

        For more information, see the respective connection documentation inIntegration Connectors.

      8. (Optional) Click+ ADD LABEL to add a label to the connection in the form of a key/value pair.
      9. ClickNext.
    3. In theAuthentication step, provide the authentication details for the connection.
      1. TheAuthentication methods populated during this step are based on the type of connection being created.

        Different connection types use different authentication methods. For more information, see theConfigure authentication section of the respective connection documentation inIntegration Connectors.

      2. ClickNext.
    4. Review: Review your connection and authentication details.
    5. ClickCreate.

Best practices

Error handling strategy

An error handling strategy for a task specifies the action to take if the task fails due to atemporary error. For information about how to use an error handling strategy, and to know about the different types of error handling strategies, seeError handling strategies.

Pricing

The Cloud Pub/Sub trigger and Salesforce trigger don't require you to create aconnector. However, if you use theConnectors task to connect to Pub/Sub or Salesforce, then you are billed for the connector usage. For information about pricing, seeApplication Integration pricing.

Quotas and limits

For information about quotas and limits, seeQuotas and limits.

What's next

Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2026-02-19 UTC.