從CSV文件讀取數據並插入到Salesforce中

我想從csv文件中讀取數據並使用Python在Salesforce中插入/插入（取決於UniqueId的存在）。我知道我必須使用迭代器從cvs文件中讀取數據，將它們放入List中，但我不確定如何從該List中獲取數據並將數據放入（插入或放入）Salesforce中。從CSV文件讀取數據並插入到Salesforce中

每個csv文件都包含兩個字段（UniqueId，Selection）。

我使用enumerate？

這裏是我到目前爲止（在那裏發生的操作）：

如何獲取數據到Salesforce？

InFiles = glob.glob(inputFolderName + '/SurveySelection*.csv') 

InFileslist = []  ##List to put file name 
for InFile in InFiles: 
    thenStamp = os.path.getmtime(InFile) 

    if (thenStamp >= unix_time(dt1)) and (thenStamp >= unix_time(dt2)): 
     InFileslist.append(InFile) ## Expression to append files in certain time range 

for filename in InFileslist: 
    file = open(filename, 'r') 
    lines = file.readlines()

來源

2017-06-14 King Java

不太清楚你的要求是什麼，但如果你不整合兩個系統爲什麼不乾脆直接導入使用，如數據導入嚮導或Salesforce的銷售人員的DataLoader提供的工具中的數據？如果你是系統整合，那麼你應該考慮使用Salesforce的REST API，或通過使用Salesforce的蟒蛇SDK

PIP安裝了Salesforce的Python-SDK

來源

2017-06-15 01:07:36

因爲我試圖從Linux服務器運行，那是停止點。 Data Loader可以從Windows機器運行，但不能從Linux運行。我正在研究什麼是Salesforce REST API。 –

我想你可以使用與加載器相關的jar文件，如果你安裝了Java，你可以從命令行運行它 –

你指的是Data Loader，是否正確？我被引用到這個網站https://github.com/forcedotcom/dataloader這是我們正在談論的？ –

目前您是在相同的位置我大約8個月前。我已成功將MySQL數據庫集成到Salesforce中。基本上，客戶將在我們的網站上註冊一個產品，然後我從數據庫中提取數據，將其格式化爲一個xlsx文件，然後使用simple-salesforce軟件包將這些數據發送到salesforce，這很好用。下面是一段代碼片斷，它可以幫助你開始。如果您有任何問題，請告訴我。

import os 
import sys 
import xlrd 
import xlwt 
import time 
import base64 
import smtplib 
import MySQLdb 
import logging 
import datetime 
import collections 
from xlrd.sheet import ctype_text 
from collections import OrderedDict 
from simple_salesforce import SFType 
from simple_salesforce import Salesforce 
from xlsxwriter.workbook import Workbook 
from MySQLdb import OperationalError 
from mysql.connector import MySQLConnection, Error 

logger = logging.getLogger('view_rows') 
hdlr = logging.FileHandler('C:\Users\Chris\Documents\Email Logs\myapp.log') 
formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s') 
hdlr.setFormatter(formatter) 
logger.addHandler(hdlr) 
logger.setLevel(logging.WARNING) 
# MySQL Database Credentials 
ur = 'user_name' # your username 
pd = 'my_password' # your password 
ht = 'localhost' # your host 
pt = 3306 
db = 'my_database' # database where your table is stored 
con = MySQLdb.connect(user=ur, passwd=pd, host=ht, port=pt, db=db) 
cursor = con.cursor() 
con.autocommit(True) 
# Salesforce Credentials 
sf = Salesforce(username='[email protected]', password='my_SF_password', security_token='my_Generated_token_from_Salesforce', client_id='This does not really matter') 
orderedDict = collections.OrderedDict() 
# Gets the new customers that have created an account on the Warranty Portal 
def GetNewContact(): 
     # Creates a xlsx file 
    workbook = Workbook('outfile.xlsx') 
    sheet = workbook.add_worksheet("Warranty Info") 
    query = "SELECT RC.cus_id, RC.cus_username, RC.cus_subsc FROM my_database.rma_customer RC INNER JOIN my_database.rma_customer_address CA ON RC.cus_id=CA.cus_id WHERE CA.cus_address_type=0 AND CA.cus_updated=1" 
    query0 = "SELECT RCD.cus_firstname, RCD.cus_lastname, RCD.cus_cell_phone FROM my_database.rma_customer_details RCD INNER JOIN my_database.rma_customer_address CA ON RCD.cus_id=CA.cus_id WHERE CA.cus_address_type=0 AND CA.cus_updated=1" 
    query1 = "SELECT CA.cus_address_1, CA.cus_address_2, CA.cus_city, CA.cus_postcode FROM my_database.rma_customer_address CA LEFT JOIN my_database.rma_customer RC ON CA.cus_id=RC.cus_id WHERE CA.cus_address_type=0 AND CA.cus_updated=1" 
    cursor.execute(query) 
    headers = ['ID', 'Email', 'Newsletter', 'FirstName', 'LastName', 'Phone', 'Street', 'APT', 'City', 'Postal'] 
    for i, header in enumerate(headers): 
     sheet.write(0, i, header) 
    for r, row in enumerate(cursor.fetchall()): 
     r = r + 1 
     for c, col in enumerate(row): 
      sheet.write(r, c, col)    
    cursor.execute(query0) 
    for r, row in enumerate(cursor.fetchall()): 
     r = r + 1 
     for c, col in enumerate(row): 
      sheet.write(r, c+3, col)   
    cursor.execute(query1) 
    for r, row in enumerate(cursor.fetchall()): 
     r = r + 1 
     for c, col in enumerate(row): 
      sheet.write(r, c+6, col) 
    #Updates the database after it has grabbed the needed info to create a contact in salesforce so that it does not get that same data again 
    workbook.close() 
def CreateContact(): 
    # Knows what file to look into for the information to create a contact 
    path = 'outfile.xlsx' 
    workbook = xlrd.open_workbook(path, on_demand = True) 
    sheet = workbook.sheet_by_index(0) 
    for rowx in xrange(1, sheet.nrows): 
     try: 
      Id = sheet.row_values(rowx, start_colx=0, end_colx=None)[0] 
      Email1 = sheet.row_values(rowx, start_colx=1, end_colx=None)[0] 
      Newsletter = sheet.row_values(rowx, start_colx=2, end_colx=None)[0] 
      First = sheet.row_values(rowx, start_colx=3, end_colx=None)[0] 
      Last = sheet.row_values(rowx, start_colx=4, end_colx=None)[0] 
      Phone = sheet.row_values(rowx, start_colx=5, end_colx=None)[0] 
      Street = sheet.row_values(rowx, start_colx=6, end_colx=None)[0] 
      Apt = sheet.row_values(rowx, start_colx=7, end_colx=None)[0] 
      City = sheet.row_values(rowx, start_colx=8, end_colx=None)[0] 
      Postal = sheet.row_values(rowx, start_colx=9, end_colx=None)[0] 
      d = sf.query("SELECT Id FROM Contact WHERE Phone ='%s' OR Email='%s'" % (Phone, Email1)) 
      # d = returns more than just a case number so data = will specifically only get the case number 
      data = [e["Id"] for e in d["records"]] 
      sf.Contact.update(data[0],{'OwnerId' : "005U0000005jwPH", 'Phone' : Phone, 'Email' : Email1, 'Newsletter__c' : Newsletter, 'MailingStreet' : Street+" "+Apt, 'MailingCity' : City, 'MailingPostalCode' : Postal, 'AccountId' : "001U000001ZEB89"}) 
      cursor.execute("UPDATE rma_customer AS RC INNER JOIN rma_customer_address CA ON RC.cus_id = CA.cus_id SET RC.SF_created=1 WHERE RC.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_address AS CA INNER JOIN rma_customer RC ON CA.cus_id = RC.cus_id SET CA.SF_created=1 WHERE CA.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_address AS CA INNER JOIN rma_customer RC ON CA.cus_id = RC.cus_id SET CA.cus_updated=0 WHERE CA.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_details AS RCD INNER JOIN rma_customer RC ON RCD.cus_id = RC.cus_id SET RCD.SF_created=1 WHERE RCD.cus_id='%s'" % Id) 
     # If Contact exists, skips and goes to next customer in excel sheet. 
     except Exception, e: 
      #print "Exception %s"%str(e) 
      Id = sheet.row_values(rowx, start_colx=0, end_colx=None)[0] 
      Email1 = sheet.row_values(rowx, start_colx=1, end_colx=None)[0] 
      Newsletter = sheet.row_values(rowx, start_colx=2, end_colx=None)[0] 
      First = sheet.row_values(rowx, start_colx=3, end_colx=None)[0] 
      Last = sheet.row_values(rowx, start_colx=4, end_colx=None)[0] 
      Phone = sheet.row_values(rowx, start_colx=5, end_colx=None)[0] 
      Street = sheet.row_values(rowx, start_colx=6, end_colx=None)[0] 
      Apt = sheet.row_values(rowx, start_colx=7, end_colx=None)[0] 
      City = sheet.row_values(rowx, start_colx=8, end_colx=None)[0] 
      Postal = sheet.row_values(rowx, start_colx=9, end_colx=None)[0] 
      logger.error("Unable to Create Contact: "+Email1+" "+Phone) 
      logger.error(e) 
      sf.Contact.create({'FirstName' : First, 'LastName' : Last, 'Newsletter__c' : Newsletter, 'Email' : Email1, 'Phone' : Phone, 'MailingStreet' : Street+" "+Apt, 'MailingCity' : City, 'MailingPostalCode' : Postal, 'AccountId' : "001U000001ZEB89"}) 
      #print "Contact Not Found. Created New Contact!" 
      cursor.execute("UPDATE rma_customer AS RC INNER JOIN rma_customer_address CA ON RC.cus_id = CA.cus_id SET RC.SF_created=1 WHERE RC.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_address AS CA INNER JOIN rma_customer RC ON CA.cus_id = RC.cus_id SET CA.SF_created=1 WHERE CA.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_address AS CA INNER JOIN rma_customer RC ON CA.cus_id = RC.cus_id SET CA.cus_updated=0 WHERE CA.cus_id='%s'" % Id) 
      cursor.execute("UPDATE rma_customer_details AS RCD INNER JOIN rma_customer RC ON RCD.cus_id = RC.cus_id SET RCD.SF_created=1 WHERE RCD.cus_id='%s'" % Id) 
      #time.sleep(10) 
     # Sleep for 30 seconds to allow Salesforce to catch up before creating the cases to ensure they are correctly associated 
    workbook.release_resources() 
    time.sleep(5) 

GetNewContact() 
CreateContact()

來源

2017-06-19 17:43:02

從CSV文件讀取數據並插入到Salesforce中

回答

相關問題