Регионализирование RegionInfo в ElasticSearch
Кажется, что RegionInfo
объект был как бы забыт с точки зрения сериализации. CultureInfo
прекрасно работает и сериализуется в строку и из строки. При попытке бросить в RegionInfo
объект, я получаю беспорядок всех свойств RegionInfo
это не может быть десериализовано, потому что нет конструктора, который принимает все эти свойства в обратном порядке. Я хотел бы просто сериализовать и десериализовать RegionInfo
как строки, как CultureInfo
, но не могу понять это.
Моя попытка:
Я создал конвертер regioninfo
public class RegionInfoConverter : JsonConverter
{
public override void WriteJson(JsonWriter writer, object value, JsonSerializer serializer)
{
serializer.Serialize(writer, ((RegionInfo)value).Name);
}
public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)
{
var token = JToken.Load(reader);
return new RegionInfo(token.ToObject<string>());
}
public override bool CanConvert(Type objectType)
{
return typeof(RegionInfo) == objectType;
}
}
Я вставил это в ConnectionSettings:
var connectionSettings = new ConnectionSettings(pool,
(builtin, settings) => new JsonNetSerializer(
builtin,
settings,
contractJsonConverters: new JsonConverter[] { new RegionInfoConverter() })
);
но я получаю ошибку: object mapping for [region] tried to parse field [region] as object, but found a concrete value
Это звучит так, как будто одна из моих частей сериализатора неправильная, но я не чувствую, что достаточно понимаю, чтобы понять, какая это часть. Благодарю.
1 ответ
Я думаю, что проблема здесь может заключаться в том, что Elasticsearch изначально предполагал object
отображение типа данных для RegionInfo
из документа, который будет проиндексирован, и теперь передается string
значение для RegionInfo
, Возможно, вам придется удалить индекс и создать заново, сопоставляя RegionInfo
собственность как keyword
тип данных.
Вот рабочий пример
private static void Main()
{
var defaultIndex = "my_index";
var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));
var settings = new ConnectionSettings(pool, (b, s) =>
new JsonNetSerializer(b, s, contractJsonConverters: new JsonConverter[] { new RegionInfoConverter() })
)
.DefaultIndex(defaultIndex);
var client = new ElasticClient(settings);
if (client.IndexExists(defaultIndex).Exists)
client.DeleteIndex(defaultIndex);
var createIndexResponse = client.CreateIndex(defaultIndex, c => c
.Settings(s => s
.NumberOfShards(1)
.NumberOfReplicas(0)
)
.Mappings(m => m
.Map<MyEntity>(mm => mm
.AutoMap()
.Properties(p => p
.Keyword(k => k
.Name(n => n.RegionInfo)
)
)
)
)
);
var indexResponse = client.Index(new MyEntity
{
RegionInfo = RegionInfo.CurrentRegion
}, i => i.Refresh(Refresh.WaitFor));
}
public class MyEntity
{
public RegionInfo RegionInfo { get; set; }
}
public class RegionInfoConverter : JsonConverter
{
public override void WriteJson(JsonWriter writer, object value, JsonSerializer serializer)
{
if (value == null)
{
writer.WriteNull();
return;
}
writer.WriteValue(((RegionInfo)value).Name);
}
public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)
{
if (reader.TokenType == JsonToken.Null)
return null;
if (reader.TokenType != JsonToken.String)
throw new JsonSerializationException($"Cannot deserialize {nameof(RegionInfo)} from {reader.TokenType}");
return new RegionInfo((string)reader.Value);
}
public override bool CanConvert(Type objectType)
{
return typeof(RegionInfo) == objectType;
}
}
Запрос индекса отправляет следующий JSON
{
"regionInfo": "AU"
}