プログラム内「-------」「--------」の部分のアドバイスをお願いしたいです。「--------」ではすでにMysqlに格納されている企業ID(com_id)とSalesforceでファイルを保持していた企業ID(Id)を比較して同じ企業であればMysqlにファイルの保存先パスを格納するというものを作ろうとしています。
「-------」
またファイル形式ごとにパスの格納先が異なり
画像であれば(picture)
その他は(attachment)
に格納したいのです。
正直どうかいていいかわからず。。。。
どなたか教えていただきたいです。
python
1import urllib3.request 2import mysql.connector 3from urllib.parse import urlparse 4 5sfdc = sf.Salesforce() 6sfdc.authenticate(client_id=client_id,client_secret=client_secret,username=username,password=password) 7 8 9接続情報のため省略 10 11 12 13#get id, filename from contentversion 14version = {} 15query_results = sfdc.query("SELECT Id, ContentDocumentId, Title, FileExtension FROM ContentVersion") 16for record in query_results["records"]: 17 if record["ContentDocumentId"] not in version: 18 version[record["ContentDocumentId"]] = [] 19 version[record["ContentDocumentId"]].append({"Id":record["Id"],"Filename":record["Title"] + "." + record["FileExtension"]}) 20 21#download) 22query_results = None 23query_results = sfdc.query("SELECT Id, ContentDocumentId, LinkedEntityId FROM ContentDocumentLink where LinkedEntityId in (SELECT Id FROM " + api_object + ")") 24for record in query_results["records"]: 25 print(record) 26 if limit_download <= 0: 27 break 28 if record["ContentDocumentId"] in version: 29 vlist = version[record["ContentDocumentId"]] 30 for v in vlist: 31 print(" downloading:" + v["Id"] + " " + v["Filename"]) 32 urlpath = "/sobjects/ContentVersion/" + v["Id"] + "/VersionData" 33 filepath = base_folder + api_object + "/" + record["LinkedEntityId"] + "/" + v["Filename"] 34 fname = v["Filename"] 35 print(fname) 36 resp = sfdc.get(urlpath) 37 limit_download -= 1 38 if not os.path.exists(os.path.dirname(filepath)): 39 os.makedirs(os.path.dirname(filepath)) 40 41 with open(filepath, "wb") as f: 42 print(filepath) 43 f.write(resp.content) 44 45 46---------------------------------------------------------------------------------------- 47 __cur = con.cursor() 48 q = "SELECT com_id from company Where com_id *******" 49 cur.execute(q) 50 if(fname == "*doc" or fname == "*docs" or fname == "*txt"): 51 print("対象外です") 52 continue 53 elif(fname == "*jpg" or fname == "*png" or fname == "*gif"): 54 q = "INSERT INTO company (picture) VALUES filepath " + \ 55 "ON DUPLICATE KEY UPDATE com_id = VALUES(com_id)" 56 cur.execute(q) 57 print("画像です") 58 else: 59 q = "INSERT INTO company (attachment) VALUES filepath " + \ 60 "ON DUPLICATE KEY UPDATE com_id = VALUES(com_id)" 61 cur.execute(q) 62 con.comit()**__ 63--------------------------------------------------------------------------------------- 64
あなたの回答
tips
プレビュー