Salesforce Create

Salesforce Create
Certified
Enterprise Edition
Create Salesforce records

Insert one or more records via the Partner API. Handles basic field type conversion and can skip duplicated input rows before sending.

yaml
type: io.kestra.plugin.ee.salesforce.Create

Examples

Create Contact records into Salesforce

yaml
id: create
namespace: company.sales

tasks:
  - id: create_contacts
    type: io.kestra.plugin.ee.salesforce.Create
    connection:
      username: "{{ secret('SALESFORCE_USERNAME') }}"
      password: "{{ secret('SALESFORCE_PASSWORD') }}"
      authEndpoint: "{{ secret('SALESFORCE_AUTH_ENDPOINT') }}"
    objectName: "Contact"
    records:
      - FirstName: "John"
        LastName: "Doe"
        Email: "john.doe@example.com"
      - FirstName: "Jane"
        LastName: "Smith"
        Email: "jane.smith@example.com"
    skipDuplicate: true

Properties

connection *

Salesforce connection

Partner API credentials using username/password with auth endpoint or access token with instance URL.

Definitions

io.kestra.plugin.ee.salesforce.SalesforceConnection

accessTokenstring

Salesforce access token

Session or OAuth access token. When set, username and password are ignored; requires instanceUrl.

authEndpointstring

Defaulthttps://login.salesforce.com/services/Soap/u/63.0/

Salesforce authentication endpoint

SOAP login endpoint used with username/password. Defaults to https://login.salesforce.com/services/Soap/u/63.0/.

instanceUrlstring

Salesforce instance URL

Instance base URL required with accessToken (for example https://mydomain.my.salesforce.com).

passwordstring

Salesforce password

Password for SOAP authentication (append the security token when required, for example <password><token>). Only used when accessToken is empty. For more details, refer to the Salesforce Documentation.

usernamestring

Salesforce username

Username for SOAP authentication. Ignored when accessToken is provided.

objectName *string

Target Salesforce object

API name of the object to insert (for example Account, Contact). See Salesforce Standard Objects.

records *array

SubTypeobject

Records to create

Array of field maps to insert. Keys must match object field API names; null values are ignored.

assets

Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.

Definitions

io.kestra.core.models.assets.AssetsDeclaration

assetFailureBehaviorstring

Possible Values

IGNOREFAILWARN

Asset failure behavior

Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.

enableAutobooleanstring

Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.

inputsarray

The assets consumed as inputs.

io.kestra.core.models.assets.AssetIdentifier

id*string

Min length1

typestring

outputs

The assets produced as outputs.

io.kestra.plugin.ee.assets.Dataset

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.File

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.Table

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.plugin.ee.assets.VM

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.External

id*string

Min length1

Max length150

type*object

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

io.kestra.core.models.assets.Custom

id*string

Min length1

Max length150

type*string

Min length1

Custom asset type

descriptionstring

displayNamestring

metadataobject

Default{}

namespacestring

Min length1

Max length150

skipDuplicate booleanstring

Defaulttrue

Skip duplicate input records

When true (default), identical entries in records are deduplicated locally before calling Salesforce. Server-side duplicate rules may still reject records.

Outputs

ids array

SubTypestring

Created record IDs

recordCount integer

Total number of records created