使用CreateSearchIndex介面在資料表上建立一個多元索引。一個資料表可以建立多個多元索引。
前提條件
- 已初始化Client。具體操作,請參見初始化。
- 已建立資料表,且資料表的資料生命週期(time_to_live)必須為-1,最大版本數(max_versions)必須為1。
參數
建立多元索引時,需要指定資料表名稱(table_name)、多元索引名稱(index_name)和索引的結構資訊(schema),其中schema包含field_schemas(Index的所有欄位的設定)、index_setting(索引設定)和index_sort(索引預排序設定)。詳細參數說明請參見下表。
組成 | 說明 |
---|---|
table_name | 資料表名稱。 |
index_name | 多元索引名稱。 |
field_schemas | field_schema的列表,每個field_schema包含如下內容:
|
index_setting | 索引設定,包含routing_fields設定。
routing_fields(可選):自訂路由欄位。可以選擇部分主鍵列作為路由欄位,在進行索引資料寫入時,會根據路由欄位的值計算索引資料的分布位置,路由欄位的值相同的記錄會被索引到相同的資料分區中。 |
index_sort | 索引預排序設定,包含sorters設定。如果不設定,則預設按照主鍵排序。
说明 含有Nested類型的索引不支援indexSort,沒有預排序。
sorters(必選):索引的預排序方式,支援按照主鍵排序和欄位值排序。關於排序的更多資訊,請參見排序和翻頁。
|
樣本
建立多元索引時設定分詞。多元索引包括k(Keyword類型)、t(Text類型)、g(Geopoint類型)、ka(數組Keyword類型)、la(數組Long類型)和n(Nested類型)六個欄位。其中n欄位包括nk(Keyword類型)、nl(Long類型)和nt(Text類型)三個子欄位。
#Keyword類型的欄位,建立索引並開啟統計彙總功能。
field_a = FieldSchema('k', FieldType.KEYWORD, index=True, enable_sort_and_agg=True, store=True)
#Text類型的欄位,建立索引並使用單字分詞。
field_b = FieldSchema('t', FieldType.TEXT, index=True, store=True, analyzer=AnalyzerType.SINGLEWORD)
#Text類型的欄位,建立索引並使用模糊分詞。
#filed_b = FieldSchema('t', FieldType.TEXT, index=True, store=True, analyzer=AnalyzerType.FUZZY,analyzer_parameter=FuzzyAnalyzerParameter(1, 6))
#Text類型的欄位,建立索引並使用自訂分隔字元半形逗號(,)進行分詞。
#field_b = FieldSchema('t', FieldType.TEXT, index=True, store=True, analyzer=AnalyzerType.SPLIT, analyzer_parameter = SplitAnalyzerParameter(","))
#Geopoint類型的欄位,建立索引。
field_c = FieldSchema('g', FieldType.GEOPOINT, index=True, store=True)
#數組Kerword類型欄位,建立索引。
field_d = FieldSchema('ka', FieldType.KEYWORD, index=True, is_array=True, store=True)
#數組Long類型欄位,建立索引。
field_e = FieldSchema('la', FieldType.LONG, index=True, is_array=True, store=True)
#Nested類型欄位,包括nk(Keyword類型)、nl(Long類型)和nt(Text類型)三個子欄位。
field_n = FieldSchema('n', FieldType.NESTED, sub_field_schemas=[
FieldSchema('nk', FieldType.KEYWORD, index=True, store=True),
FieldSchema('nl', FieldType.LONG, index=True, store=True),
FieldSchema('nt', FieldType.TEXT, index=True, store=True),
])
fields = [field_a, field_b, field_c, field_d, field_e, field_n]
index_setting = IndexSetting(routing_fields=['PK1'])
index_sort = None #當多元索引中存在Nested類型欄位時,不能設定索引預排序.
#index_sort = Sort(sorters=[PrimaryKeySort(SortOrder.ASC)])
index_meta = SearchIndexMeta(fields, index_setting=index_setting, index_sort=index_sort)
client.create_search_index(table_name, index_name, index_meta)