Occasional non-association of a contact and a deal via Ecomm bridge
SOLVE
1 Accepted solution
Accepted Solutions
.png "HubSpot Employee"){kind=icon}
Thanks for your input @IsaacTakushi
Yep, we create contact first, then the deal, then the line item. We're seeing this non-association constantly and frankly, it's a bit disappointing.
We came up with a minimal test case (below) and started introducing delays between contact and deal creation. Up until we ramp up the delay to 5 seconds we see non-assocs. From where I stand, it's just some race condition or just a slow endpoint 
import json
import datetime
import time
from urllib.parse import urlencode
from urllib.request import Request, urlopen
BASE_URL = 'https://api.hubapi.com/'
HS_KEY = 'd4e6cdb1-wiped-for-security-reasons'
START_FROM = 50
NUMBER = 10
DELAY = 5.0
def upload_fake(start_from, n):
for i in range(start_from, start_from + n):
si = str(i)
print(si)
contact_id = 'fake-contact-' + si
deal_id = 'fake-deal-' + si
contact = {
'integratorObjectId': contact_id,
'action': 'UPSERT',
'changeOccurredTimestamp': unixtime_now(),
'propertyNameToValues': {
'firstname': 'Name' + si,
'lastname': 'Surname' + si,
'email_0': 'user' + si + '@fakeusers.com',
'city': 'Gotham City',
'state': 'NY',
'country': 'US',
}
}
ecomm_sync_contacts([contact])
time.sleep(DELAY)
deal = {
'integratorObjectId': deal_id,
'action': 'UPSERT',
'changeOccurredTimestamp': unixtime_now(),
'propertyNameToValues': {
'dealname': 'deal' + si,
'amount': '100.00',
'dealstage': 'checkout_completed',
'hs_assoc__contact_ids': contact_id,
}
}
ecomm_sync_deals([deal])
time.sleep(DELAY)
def unixtime_now():
UNIX_EPOCH = datetime.datetime(1970, 1, 1)
dt = datetime.datetime.utcnow()
ut = int((dt - UNIX_EPOCH) / datetime.timedelta(seconds=1)) * 1000
return ut
def ua_put_json(suburl, payload):
url = BASE_URL + suburl + '?hapikey=' + HS_KEY
body = json.dumps(payload).encode()
req = Request(url,
data=body,
headers={
'Content-Type': 'application/json',
},
method='PUT')
resp = urlopen(req).read().decode()
# print(resp)
# --- Ecommerce Bridge sync -----------------------------------------------
def ecomm_sync_contacts(contacts):
r = ua_put_json(
'extensions/ecomm/v1/sync-messages/CONTACT', payload=contacts)
return r
def ecomm_sync_products(products):
r = ua_put_json(
'extensions/ecomm/v1/sync-messages/PRODUCT', payload=products)
return r
def ecomm_sync_deals(deals):
r = ua_put_json(
'extensions/ecomm/v1/sync-messages/DEAL', payload=deals)
return r
def ecomm_sync_line_items(items):
r = ua_put_json(
'extensions/ecomm/v1/sync-messages/LINE_ITEM', payload=items)
return r
def main():
upload_fake(START_FROM, NUMBER)
main()
