jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(connector): fix the s3 upload method's signature

Browse source
This commit is contained in:
Alexander 2025-01-28 14:39:10 +01:00
parent 2b05bb59af
commit c83dec7774
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
ee/backend/pkg/connector/s3batches.go
View file

@ -25,7 +25,7 @@ func NewBatches(cfg *connector.Config, objStorage objectstorage.ObjectStorage) (
func (ds *Batches) Insert(batch []map[string]string, fileName string, columns []string) error {
buf := dataToCSV(batch, columns)
reader := bytes.NewReader(buf.Bytes())
if err := ds.objStorage.Upload(reader, fileName, "text/csv", objectstorage.NoCompression); err != nil {
if err := ds.objStorage.Upload(reader, fileName, "text/csv", objectstorage.NoContentEncoding, objectstorage.NoCompression); err != nil {
return fmt.Errorf("can't upload file to s3: %s", err)
}
return nil
@ -34,7 +34,7 @@ func (ds *Batches) Insert(batch []map[string]string, fileName string, columns []
func (ds *Batches) InsertTSV(batch []map[string]string, fileName string, columns []string) error {
buf := dataToTSV(batch, columns)
reader := bytes.NewReader(buf.Bytes())
if err := ds.objStorage.Upload(reader, fileName, "text/tsv", objectstorage.NoCompression); err != nil {
if err := ds.objStorage.Upload(reader, fileName, "text/tsv", objectstorage.NoContentEncoding, objectstorage.NoCompression); err != nil {
return fmt.Errorf("can't upload file to s3: %s", err)
}
return nil