Ce contenu n'est pas disponible dans la langue sélectionnée.

Chapter 61. Salesforce Create Sink

Creates an object in Salesforce. The body of the message must contain the JSON of the salesforce object.

Example body: { "Phone": "555", "Name": "Antonia", "LastName": "Garcia" }

61.1. Configuration Options

The following table summarizes the configuration options available for the salesforce-create-sink Kamelet:

Property	Name	Description	Type	Default	Example
clientId *	Consumer Key	The Salesforce application consumer key	string
clientSecret *	Consumer Secret	The Salesforce application consumer secret	string
password *	Password	The Salesforce user password	string
userName *	Username	The Salesforce username	string
loginUrl	Login URL	The Salesforce instance login URL	string	`"https://login.salesforce.com"`
sObjectName	Object Name	Type of the object	string		`"Contact"`

Note

Fields marked with an asterisk (*) are mandatory.

61.2. Dependencies

At runtime, the salesforce-create-sink Kamelet relies upon the presence of the following dependencies:

camel:salesforce
camel:kamelet

61.3. Usage

This section describes how you can use the salesforce-create-sink.

61.3.1. Knative Sink

You can use the salesforce-create-sink Kamelet as a Knative sink by binding it to a Knative object.

salesforce-create-sink-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: salesforce-create-sink-binding
spec:
  source:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: salesforce-create-sink
    properties:
      clientId: "The Consumer Key"
      clientSecret: "The Consumer Secret"
      password: "The Password"
      userName: "The Username"

61.3.1.1. Prerequisite

Make sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.

61.3.1.2. Procedure for using the cluster CLI

Save the salesforce-create-sink-binding.yaml file to your local drive, and then edit it as needed for your configuration.

Run the sink by using the following command:

oc apply -f salesforce-create-sink-binding.yaml

61.3.1.3. Procedure for using the Kamel CLI

Configure and run the sink by using the following command:

kamel bind channel:mychannel salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"

This command creates the KameletBinding in the current namespace on the cluster.

61.3.2. Kafka Sink

You can use the salesforce-create-sink Kamelet as a Kafka sink by binding it to a Kafka topic.

salesforce-create-sink-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: salesforce-create-sink-binding
spec:
  source:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: salesforce-create-sink
    properties:
      clientId: "The Consumer Key"
      clientSecret: "The Consumer Secret"
      password: "The Password"
      userName: "The Username"

61.3.2.1. Prerequisites

Ensure that you’ve installed the AMQ Streams operator in your OpenShift cluster and created a topic named my-topic in the current namespace. Make also sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.

61.3.2.2. Procedure for using the cluster CLI

Save the salesforce-create-sink-binding.yaml file to your local drive, and then edit it as needed for your configuration.

Run the sink by using the following command:

oc apply -f salesforce-create-sink-binding.yaml

61.3.2.3. Procedure for using the Kamel CLI

Configure and run the sink by using the following command:

kamel bind kafka.strimzi.io/v1beta1:KafkaTopic:my-topic salesforce-create-sink -p "sink.clientId=The Consumer Key" -p "sink.clientSecret=The Consumer Secret" -p "sink.password=The Password" -p "sink.userName=The Username"

This command creates the KameletBinding in the current namespace on the cluster.

61.4. Kamelet source file

https://github.com/openshift-integration/kamelet-catalog/salesforce-create-sink.kamelet.yaml