yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-12-12 15:57:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

table-name-fail-fix- (#3114)

Browse Source
This commit is contained in:
codingwithabhi 2022-03-04 03:14:34 +05:30 committed by GitHub
parent 84fd717c57
commit 37457dc668
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
ingestion/examples/workflows/redshift.json
View File

@ -9,7 +9,8 @@
"service_name": "aws_redshift", "service_name": "aws_redshift",
"table_filter_pattern": { "table_filter_pattern": {
"excludes": ["information_schema.*", "[\\w]*event_vw.*"] "excludes": ["information_schema.*", "[\\w]*event_vw.*"]
} },
"query":"select * from \"{}\".\"{}\" Limit 50"
} }
}, },
"sink": { "sink": {

1
ingestion/src/metadata/ingestion/source/redshift.py
View File

@ -224,6 +224,7 @@ class RedshiftConfig(SQLConnectionConfig):
where_clause: Optional[str] = None where_clause: Optional[str] = None
duration: int = 1 duration: int = 1
service_type = DatabaseServiceType.Redshift.value service_type = DatabaseServiceType.Redshift.value
query = 'select * from "{}"."{}"'
def get_identifier(self, schema: str, table: str) -> str: def get_identifier(self, schema: str, table: str) -> str:
""" """