Skip to content

Instantly share code, notes, and snippets.

@dajor
Created October 22, 2019 05:58
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dajor/eb18d92a25ba657bbe0aae87798f6e0a to your computer and use it in GitHub Desktop.
Save dajor/eb18d92a25ba657bbe0aae87798f6e0a to your computer and use it in GitHub Desktop.
import logging
import azure.functions as func
import os, io, crm, json
import pandas as pd
from sugarcrm.client import Client
def main(myblob: func.InputStream):
logging.info(f"Python blob trigger function processed blob \n"
f"Name: {myblob.name}\n"
f"Blob Size: {myblob.length} bytes")
file = myblob.read()
csvf = io.BytesIO(file)
csvf = csvf.getvalue().decode('UTF-8')
sniffer = csv.Sniffer()
cnt = sniffer.sniff(csvf)
logging.info (cnt.delimiter)
df = pd.read_csv(io.BytesIO(file), sep=cnt.delimiter, dtype=str)
client = Client('https://sg-python.demo.sugarcrm.eu', 'admin', '***')
results = []
results = json.loads(df.to_json(orient='records'))
for item in results:
logging.info("Import")
#item['id'] = item['CONTRACT_ID']
logging.info(json.dumps(item,indent=2))
client.set_entry('Leads', item )
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment