import arcpy
import csv
import json
import requests
#Acqua Device (ID: 1) "sourceId": 9,
#Acqua Junction (ID: 2) "sourceId": 12,
#Structure Junction (ID: 3) "sourceId": 4,
# Configurazione
username = 'xyz'
password = "xyz"
csv_path = r"C:\ArcGIS\26_xxx_UN\Creazione_UtilityNetwork\PRO prj\File_GDB\Association_xxx_2025_04_01_ore1811_DEVICE.csv"
# Funzione per ottenere il token se necessario
def get_token():
token = generateToken(username, password, portalUrl)
return token
def generateToken(username, password, portalUrl😞
# Retrieves a token to be used with API requests.
headers = {'content-type': 'application/x-www-form-urlencoded'}
parameters = {'username': username,
'password': password,
'client': 'referer',
'referer': portalUrl,
'expiration': 60,
'f': 'json'}
url = portalUrl + '/sharing/rest/generateToken?'
response = requests.post(url, data=parameters, headers=headers)
try:
jsonResponse = response.json()
if 'token' in jsonResponse:
return jsonResponse['token']
elif 'error' in jsonResponse:
print(jsonResponse['error']['message'])
for detail in jsonResponse['error']['details']:
print(detail)
except ValueError:
print('An unspecified error occurred.')
print(ValueError)
# Leggere il CSV e creare le associazioni
associations = []
with open(csv_path, 'r', encoding='utf-8') as file:
reader = csv.reader(file)
header = next(reader) # Legge l'intestazione
for row in reader:
if len(row) != 13:
print(f"Errore: Riga non conforme -> {row}")
continue
association = {
"attributes": {
"ASSOCIATIONTYPE" : 2,
#"ISCONTENTVISIBLE" : <0|1>, // optional: false, true
"FROMNETWORKSOURCEID" : 4,
"FROMGLOBALID" : row[4],
#"FROMTERMINALID" : <long>, // optional
"TONETWORKSOURCEID" : 9,
"TOGLOBALID" : row[9],
#"TOTERMINALID" : <long>, // optional
#"PERCENTALONG" : <float> // optional
"ISCONTENTVISIBLE" : 0
}
}
associations.append(association)
# Invia le associazioni al Feature Service
payload = [
{
"id": 500001, # Modifica con l'ID corretto del layer delle associazioni
"adds": associations
}
]
# Funzione per inviare modifiche al Feature Service
def apply_edits(payload😞
url = f"{feature_service_url}/applyEdits"
data = {"geodatabaseVersionName" : "sde.DEFAULT", "useGlobalIds" : "true", "f": "json", "token": get_token(), "edits": json.dumps(payload)}
response = requests.post(url, data=data)
return response.json()
# Esegui l'importazione
result = apply_edits(payload)
print("Risultato dell'importazione:", result)
# Miglioramento: Gestione degli errori per il risultato
if 'error' in result:
print("association:",association)
print("Errore durante l'importazione:", result['error'])
else:
print("Importazione completata con successo.")
but I had the following error:
Errore durante l'importazione: {'code': 400, 'extendedCode': -2147219118, 'message': 'Unable to complete operation.', 'details': ['Internal error while adding containment association. A requested row object could not be located.']}
association content is:
association: {'attributes': {'ASSOCIATIONTYPE': 2, 'FROMNETWORKSOURCEID': 4, 'FROMGLOBALID': '{450CCDC5-24AA-4018-9001-793E856513CB}', 'TONETWORKSOURCEID': 9, 'TOGLOBALID': '{5679CD23-D8EC-44DA-95C5-87632E35D40E} ', 'ISCONTENTVISIBLE': 0}}
what could be wrong?
