mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-09-09 09:02:12 +00:00
parent
b41b7d8bfb
commit
0b789788da
@ -876,7 +876,7 @@ class GlossaryTermESIndex extends ElasticSearchIndex {
|
|||||||
.name(glossaryTerm.getName())
|
.name(glossaryTerm.getName())
|
||||||
.displayName(displayName)
|
.displayName(displayName)
|
||||||
.description(description)
|
.description(description)
|
||||||
.fqdn(glossaryTerm.getName())
|
.fqdn(glossaryTerm.getFullyQualifiedName())
|
||||||
.glossaryId(glossaryTerm.getGlossary().getId().toString())
|
.glossaryId(glossaryTerm.getGlossary().getId().toString())
|
||||||
.glossaryName(glossaryTerm.getGlossary().getName())
|
.glossaryName(glossaryTerm.getGlossary().getName())
|
||||||
.lastUpdatedTimestamp(updatedTimestamp)
|
.lastUpdatedTimestamp(updatedTimestamp)
|
||||||
|
@ -9,6 +9,9 @@
|
|||||||
"owner": {
|
"owner": {
|
||||||
"type": "keyword"
|
"type": "keyword"
|
||||||
},
|
},
|
||||||
|
"fqdn": {
|
||||||
|
"type": "keyword"
|
||||||
|
},
|
||||||
"last_updated_timestamp": {
|
"last_updated_timestamp": {
|
||||||
"type": "date",
|
"type": "date",
|
||||||
"format": "epoch_second"
|
"format": "epoch_second"
|
||||||
|
@ -197,6 +197,7 @@ class GlossaryTermESDocument(BaseModel):
|
|||||||
entity_type: str = "glossaryTerm"
|
entity_type: str = "glossaryTerm"
|
||||||
name: str
|
name: str
|
||||||
display_name: str
|
display_name: str
|
||||||
|
fqdn: str
|
||||||
description: str
|
description: str
|
||||||
glossary_name: str
|
glossary_name: str
|
||||||
glossary_id: str
|
glossary_id: str
|
||||||
|
@ -12,12 +12,10 @@
|
|||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
import ssl
|
import ssl
|
||||||
import time
|
|
||||||
import traceback
|
import traceback
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
|
|
||||||
from dateutil import parser
|
|
||||||
from elasticsearch import Elasticsearch
|
from elasticsearch import Elasticsearch
|
||||||
from elasticsearch.connection import create_ssl_context
|
from elasticsearch.connection import create_ssl_context
|
||||||
|
|
||||||
@ -578,6 +576,7 @@ class ElasticsearchSink(Sink[Entity]):
|
|||||||
deleted=glossary_term.deleted,
|
deleted=glossary_term.deleted,
|
||||||
name=glossary_term.name.__root__,
|
name=glossary_term.name.__root__,
|
||||||
display_name=glossary_term.displayName,
|
display_name=glossary_term.displayName,
|
||||||
|
fqdn=glossary_term.fullyQualifiedName,
|
||||||
description=glossary_term.description,
|
description=glossary_term.description,
|
||||||
glossary_id=str(glossary_term.glossary.id.__root__),
|
glossary_id=str(glossary_term.glossary.id.__root__),
|
||||||
glossary_name=glossary_term.glossary.name,
|
glossary_name=glossary_term.glossary.name,
|
||||||
|
@ -477,6 +477,9 @@ GLOSSARY_TERM_ELASTICSEARCH_INDEX_MAPPING = textwrap.dedent(
|
|||||||
"display_name": {
|
"display_name": {
|
||||||
"type": "text"
|
"type": "text"
|
||||||
},
|
},
|
||||||
|
"fqdn": {
|
||||||
|
"type": "keyword"
|
||||||
|
},
|
||||||
"owner": {
|
"owner": {
|
||||||
"type": "keyword"
|
"type": "keyword"
|
||||||
},
|
},
|
||||||
|
Loading…
x
Reference in New Issue
Block a user