-
Notifications
You must be signed in to change notification settings - Fork 465
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[copy_from] AWS source #31144
[copy_from] AWS source #31144
Conversation
7defd19
to
58f62b2
Compare
58f62b2
to
b9715b2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, but I think we should add tests for this.
src/aws-util/src/s3.rs
Outdated
use aws_types::sdk_config::SdkConfig; | ||
|
||
pub use aws_sdk_s3::Client; | ||
use bytes::Bytes; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this is meant to go in the other import block?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ahh yeah I should move this up, thanks!
* add a new OneshotSource implementation * support the FILES and PATTERN options for COPY FROM
b9715b2
to
4f8ab12
Compare
I have a bunch of tests in a stacked PR, will get those up for review! |
Stacked on top of: #30956
This PR implements a new AwsS3
OneshotSource
that allows copying in files from S3, e.g.Along with
FILES = [<files>]
we also support aPATTERN = <glob>
option which allows copying multiple files all at once.Motivation
Fixes https://github.com/MaterializeInc/database-issues/issues/8860
Fixes https://github.com/MaterializeInc/database-issues/issues/8855
Tips for reviewer
Review only the final commit, the one titled "start, implementation of an S3 oneshot source"
Checklist
$T ⇔ Proto$T
mapping (possibly in a backwards-incompatible way), then it is tagged with aT-proto
label.