mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-10-31 02:29:03 +00:00
703abc52f4
* Doc: Meta updation * Doc: Meta updation --------- Co-authored-by: “Rounak <“rounakpreet.d@deuexsolutions.com”> Co-authored-by: Ayush Shah <ayush@getcollate.io> Co-authored-by: Prajwal214 <167504578+Prajwal214@users.noreply.github.com>
1.1 KiB
1.1 KiB
| title | description | slug |
|---|---|---|
| Sink | Learn to build custom sink connectors for OpenMetadata using Python SDK. Step-by-step guide with code examples to integrate and stream metadata efficiently. | /sdk/python/build-connector/sink |
Sink
The Sink will get the event emitted by the source, one at a time. It can use this record to make external service calls to store or index etc.For OpenMetadata we have MetadataRestTablesSink.
API
class Sink(ReturnStep, ABC):
"""All Sinks must inherit this base class."""
# From the parent - Just to showcase
@abstractmethod
def _run(self, record: Entity) -> Either:
"""
Main entrypoint to execute the step
"""
_run this method is called for each record coming down in the workflow chain and can be used to store the record in external services etc.