Elasticsearch Bulk and Search!
Elasticsearch Bulk and Search is a high level library to make easy basic query operations (get, search and scroll) and index operations (single index or bulk), besides paging, sorting and query buider.
Sample
Sample Entity Class (Person)
public class Person
{
public string Id { get; set; }
public DateTime CreateDate { get; set; }
public string Name { get; set; }
public int Age { get; set; }
public static string GenerateIndexName(string defaultIndex, Person person)
{
var suffix = person.CreateDate.ToString("yyyy-MM");
return $"{defaultIndex}-{suffix}";
}
}Init commad and query objects
var elasticsearchOptions = new ElasticsearchOptions
{
WriteUrl = "http://localhost:9200",
ReadUrl = "http://localhost:9200",
DefaultTypeName = "docs",
TimeoutInSeconds = 60,
MaximumRetries = 5,
User = "user",
Pass = "pass"
};
IElasticsearchCommand<Person> PersonCommand = new ElasticsearchCommand<Person>(elasticsearchOptions, Person.GenerateIndexName);
IElasticsearchQuery<Person> PersonQuery = new ElasticsearchQuery<Person>(elasticsearchOptions);
Using GenerateIndexName you can customize index per document based on your properties (used to create timed index);
Basic commands
// bulk
var persons = new List<Person>
{
{ new Person { Id = "1", Name = "Thiago Barradas", Age = 27, CreateDate = new DateTime(2019, 01, 01) } },
{ new Person { Id = "8", Name = "Ralph Legal", Age = 29, CreateDate = new DateTime(2018, 12, 01) } },
{ new Person { Id = "9", Name = "James Bond", Age = 30, CreateDate = new DateTime(2018, 12, 10) } },
{ new Person { Id = "10", Name = "John Doe", Age = 54, CreateDate = new DateTime(2018, 11, 01) } },
{ new Person { Id = "11", Name = "Jow Troll Moon Do", Age = 58, CreateDate = new DateTime(2018, 05, 25) } }
};
PersonCommand.Bulk(persons);
// upsert
var otherPerson = new Person { Id = "2", Name = "Rafael Barradas", Age = 25, CreateDate = new DateTime(2018, 12, 01) };
PersonCommand.Upsert(otherPerson);Basic queries
// get by id
Person personX = PersonQuery.Get("8");
Person personY = PersonQuery.Get(4);
// search
var searchOptions = new SearchOptions
{
Page = 1,
Size = 1,
SortField = "name.keyword",
SortMode = SortMode.ASC
};
var query = Query<Person>.DateRange(i => i.Field("createDate").LessThan("2018-12-01"));
var searchResult = PersonQuery.Search(query, searchOptions);
// scroll
var scrollOptions = new ScrollOptions
{
Scroll = "1m",
Size = 2,
SortField = "name.keyword",
SortMode = BulkAndSearch.Models.SortMode.ASC
};
List<Person> scrollPersons = new List<Person>();
var scrollResult = PersonQuery.Scroll(query, scrollOptions);
while (scrollResult.Items.Any())
{
scrollPersons.AddRange(scrollResult.Items);
scrollResult = PersonQuery.Scroll(query, scrollOptions);
}When some error occurred, an exception is thrown;
Install via NuGet
PM> Install-Package Easy.Elasticsearch.BulkAndSearch
How can I contribute?
Please, refer to CONTRIBUTING
Found something strange or need a new feature?
Open a new Issue following our issue template ISSUE_TEMPLATE
Changelog
See in nuget version history
Did you like it? Please, make a donate :)
if you liked this project, please make a contribution and help to keep this and other initiatives, send me some Satochis.
BTC Wallet: 1G535x1rYdMo9CNdTGK3eG6XJddBHdaqfX
