'Create new connection to Salesforce
and allows you to pull data out of SFDC and save it to a file.
You can then use that file with other
Airflow operators to move the data into another data source
:param conn_id:     the name of the connection that has the parameters
we need to connect to Salesforce.
The conenction shoud be type `http` and include a
user\'s security token in the `Extras` field.
.. note::
For the HTTP connection type, you can include a
JSON structure in the `Extras` field.
We need a user\'s security token to connect to Salesforce.
So we define it in the `Extras` field as:
`{"security_token":"YOUR_SECRUITY_TOKEN"}`'

def __init__(self, conn_id, *args, **kwargs):

    self.conn_id = conn_id
    self._args = args
    self._kwargs = kwargs
    self.connection = self.get_connection(conn_id)
    self.extras = self.connection.extra_dejson
