В настоящее время я пытаюсь объединить данные, используя следующий код
for i, entry in enumerate(result):
aux = encode(entry)
body.append({
"_index": "laborum_profiles",
"_type": "profile",
"_id": aux["id"],
"_source": {
"@timestamp": datetime.now(),
"@version": "1",
"address": aux["location"] if "location" in aux else "",
# Here I'm using a function to calculate the age
"age": age_calculus(aux["birthDate"]) if "birthDate" in aux else 0,
"birthday": aux["birthDate"] if "birthDate" in aux else None,
"cellphone": aux["phones"] if "phones" in aux else [],
"country": aux["nationality"] if "nationality" in aux else "",
"creation_date": aux["createdAt"] if "createdAt" in aux else None,
}
})
helpers.bulk(es, body)
Интересно, если это хорошая практика, если нет, что еще можно попробовать? Я делаю это, потому что в базе данных много пустых данных.