create

get

from prefect import flow, task
from simple_salesforce import Salesforce
import requests

@task()
def create_sf_account(un, pw, tk):
     session = requests.Session()
# manipulate the session instance (optional)
       sf = Salesforce(
   username=un, password=pw, token=tk)
        sf.Account.create({'Name':'Smith','Email':'<mailto:example@example.com|example@example.com>'})


@task()
def get_sf_data(un, pw, tk):
    sf = Salesforce(username=un, password=pw, security_token=tk, domain="test")
    query = f"SELECT Id, Name FROM Accounts"
    data = sf.query(query)
    records = data["records"]
    return records

@flow
def salesforce_example():
   salesforce_accounts = get_sf_data(username, password, token)