Hi, I am trying to update custom fields for contacts between sends. If I add a contact via the bulk API, send a message, and then add the user again later with additional custom fields (in hopes of updating the user), those new custom fields aren't added.
Here's a sample test script which adds a user via the bulk API, prints its custom fields, adds it again with a new custom field, and prints its custom fields again. After "uploading file 2", it should show an additional line, CustomField2 = field2, but does not.
$ python test/contacttest.py
uploading file 1
CustomField1 = field1
uploading file 2
CustomField1 = field1
$ cat test/conttacttest.py
#!/usr/bin/env python
import requests
import json
import sys
import time
api_key='...'
access_token='...'
me='my@email.com'
def upload(list_id, contents):
params={'api_key': api_key, 'access_token': access_token},
data={'lists': [list_id], 'file_name': 'upload.csv'},
files={'data': contents})
upload_id = r.json()['id']
for i in xrange(10):
params={'api_key': api_key, 'access_token': access_token})
if r.json()['status'].lower() == 'complete':
return True
else:
time.sleep(10)
return False
if __name__ == '__main__':
params={'api_key': api_key, 'access_token': access_token},
data=json.dumps({ 'name': 'test list %s' % int(time.time()), 'status': 'ACTIVE' }))
if r.status_code != 201:
print r.text
sys.exit(1)
list_id = r.json()['id']
print 'uploading file 1'
file1 = '''
Email,Custom Field 1
%s,field1
''' % me
t = upload(list_id, file1)
if not t:
print 'problem uploading'
sys.exit(1)
params={'api_key': api_key, 'access_token': access_token, 'email': me})
if r.status_code != 200:
print r.status_code
print r.text
sys.exit(1)
for record in r.json()['results']:
if me in [i['email_address'] for i in record.get('email_addresses', [])]:
for field in sorted(record['custom_fields'], key=lambda v: v['name']):
print '%s = %s' % (field['name'], field['value'])
print 'uploading file 2'
file2 = '''
Email,Custom Field 1,Custom Field 2
%s,field1,field2
''' % me
t = upload(list_id, file2)
if not t:
print 'problem uploading'
sys.exit(1)
params={'api_key': api_key, 'access_token': access_token, 'email': me})
if r.status_code != 200:
print r.status_code
print r.text
sys.exit(1)
for record in r.json()['results']:
if me in [i['email_address'] for i in record.get('email_addresses', [])]:
for field in sorted(record['custom_fields'], key=lambda v: v['name']):
print '%s = %s' % (field['name'], field['value'])
