6.WokflowCore之Elasticsearch搜索

步步为营DotNet

发布于 2026-06-17 09:21:26

50

Elasticsearch搜索

nuget安装WorkflowCore.Providers.Elasticsearch

设置

using Nest;
services.AddWorkflow(cfg =>
{
    ...
    cfg.UseElasticsearch(new ConnectionSettings(new Uri("http://localhost:9200")), "index_name");
});

使用

将ISearchIndex服务注入，并调用Search方法

Search(string terms, int skip, int take, params SearchFilter[] filters)

terms

以空格分隔的搜索字符串，空字符串会匹配到所有内容。该字符串会对工作流的描述、引用、状态、工作流定义进行搜索。

如果自定义数据对象实现了ISearchable，则可以在自定义数据对象中进行搜索。

 using WorkflowCore.Interfaces;
 ...
 public class MyData : ISearchable
{
    public string StrValue1 { get; set; }
    public string StrValue2 { get; set; }

    public IEnumerable<string> GetSearchTokens()
    {
        return new List<string>()
        {
            StrValue1,
            StrValue2
        };    
    }
}

searchIndex.Search("puppies", 0, 10);查询所有包含puppies字段

skip/take

跳过多少，取多少

filters

用于搜索的筛选器列表，可以用来刷选标量、日期范围、数字范围、状态

案例：

通过引用过滤

 using WorkflowCore.Models.Search;
 ...
 searchIndex.Search("", 0, 10, ScalarFilter.Equals(x => x.Reference, "My Reference"));

通过启动工作流的日期

searchIndex.Search("", 0, 10, DateRangeFilter.After(x => x.CreateTime, startDate));

通过期间

searchIndex.Search("", 0, 10, DateRangeFilter.Between(x => x.CompleteTime, startDate, endDate));

通过状态

searchIndex.Search("", 0, 10, StatusFilter.Equals(WorkflowStatus.Complete));

筛选自定义数据类

class MyData
 {
	public string Value1 { get; set; }
	public int Value2 { get; set; }
 }

 searchIndex.Search("", 0, 10, ScalarFilter.Equals<MyData>(x => x.Value1, "blue moon"));
 searchIndex.Search("", 0, 10, NumericRangeFilter.LessThan<MyData>(x => x.Value2, 5))

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2026-06-16，如有侵权请联系 cloudcommunity@tencent.com 删除

搜索