60 lines
1.8 KiB
Python
60 lines
1.8 KiB
Python
import requests
|
|
import json
|
|
import pprint
|
|
import csv
|
|
import pandas as pd
|
|
import Apikeys
|
|
import time
|
|
|
|
pp = pprint.PrettyPrinter(indent=4)
|
|
APIKEY = Apikeys.KARBON
|
|
HEADERS = {
|
|
"accept": "application/json",
|
|
"X-Api-Key": APIKEY,
|
|
}
|
|
BASEURL = "https://api.northpass.com/v2/"
|
|
IMPORTFILE = "/Users/normrasmussen/Downloads/karbon-invite-users.csv"
|
|
|
|
|
|
def bulk_invite_and_group():
|
|
"""
|
|
Bulk endpoint which invites new people and adds them to a group via this structure:
|
|
{
|
|
"email": "me@mac.com"
|
|
"groups": "GroupA"
|
|
}
|
|
|
|
This function looks for the group in the CSV as well.
|
|
"""
|
|
groups_list = []
|
|
df = pd.DataFrame()
|
|
data = pd.read_csv(IMPORTFILE)
|
|
df2 = data[[ "email", "customer_name", "customer_id" ]].copy()
|
|
customer_ids = df2["customer_id"].unique()
|
|
customer_ids = list(customer_ids)
|
|
for row in df2.itertuples():
|
|
groupname = f"{row[2]}--{row[3]}"
|
|
groups_list.append(groupname)
|
|
|
|
for customer in customer_ids:
|
|
payload = ""
|
|
tmp_group = data[data['customer_id'] == customer]
|
|
people = list(tmp_group["email"])
|
|
cust = str(tmp_group["customer_id"].unique())[2:-2]
|
|
url = f"{BASEURL}bulk/people"
|
|
payload_1 = []
|
|
for group in groups_list:
|
|
for person in people:
|
|
if cust in group:
|
|
miniload = {"email": person, "groups": group}
|
|
payload_1.append(miniload)
|
|
print(f"The {group} payload has {len(payload_1)}")
|
|
payload = {"data": {"attributes": {"people": payload_1}}}
|
|
print(payload)
|
|
response = requests.post(url, headers=HEADERS, json=payload)
|
|
print(f"Completed. Status code is {response.status_code}")
|
|
print(response.text)
|
|
|
|
if __name__ == "__main__":
|
|
bulk_invite_and_group()
|