feathr-ai / feathr-ai/feathr

A Simple way to validate Data sources connectivity in Spark Job

Open
#66 0 comments 0 reactions 0 assignees View on GitHub
feature
Dominant language
Scala
Stars
1.9k
Forks
247
PR merge metrics
No merged PRs in 30d

Description

When more and more data sources are involved, current E2E test is not scalable for pure connectivity test.
A separate spark job to simply try to **load all registered data sources into data frame** can help to

- **Enhance Test and Engineer Experience**
- Scalable data format supportive check
- Validate data connectivity for customized data source
- Further Usage in Feature Store UI / Data Platform*
- Data Source Healthy Telemetry (Daily job)
- Data Visualization Sampling/Distribution

To achieve this, we may need to have:

- **A list of sample data source** which covers every support data formats (can be a config file synced to sample feature registry) with
- data path
- credential pointer (to a centralized credential storage, e.g. Key Vault)
- rules* (customized rules to make sure data source meets requirements)
- **Credential Storage**
- key or token
- access type*: e.g. admin / read / write...
- access level*: e.g. single file / folder; table / storage...
- **DataSourceCheckJob(ss, Seq[dataSourceDef])**

"*" : means nice to have & low priority

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.