diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-24 00:32:35 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-24 00:32:35 -0700 |
| commit | 7c39a18ba5985cfcd40fbccea0945874b297d9f2 (patch) | |
| tree | 547f32699da6a6bf64cf7f9d5d899c72773aac91 /weed | |
| parent | a78d0227cd504b3492c4ad8798409b3982385977 (diff) | |
| download | seaweedfs-7c39a18ba5985cfcd40fbccea0945874b297d9f2.tar.xz seaweedfs-7c39a18ba5985cfcd40fbccea0945874b297d9f2.zip | |
update azure library
Diffstat (limited to 'weed')
| -rw-r--r-- | weed/replication/sink/azuresink/azure_sink.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/replication/sink/azuresink/azure_sink.go b/weed/replication/sink/azuresink/azure_sink.go index 0ac32b5c1..3b944e5b7 100644 --- a/weed/replication/sink/azuresink/azure_sink.go +++ b/weed/replication/sink/azuresink/azure_sink.go @@ -62,7 +62,7 @@ func (g *AzureSink) initialize(accountName, accountKey, container, dir string) e // Use your Storage account's name and key to create a credential object. credential, err := azblob.NewSharedKeyCredential(accountName, accountKey) if err != nil { - glog.Fatalf("failed to create Azure credential with account name:%s key:%s", accountName, accountKey) + glog.Fatalf("failed to create Azure credential with account name:%s: %v", accountName, err) } // Create a request pipeline that is used to process HTTP(S) requests and responses. @@ -109,13 +109,13 @@ func (g *AzureSink) CreateEntry(key string, entry *filer_pb.Entry, signatures [] // Azure Storage account's container. appendBlobURL := g.containerURL.NewAppendBlobURL(key) - _, err := appendBlobURL.Create(context.Background(), azblob.BlobHTTPHeaders{}, azblob.Metadata{}, azblob.BlobAccessConditions{}) + _, err := appendBlobURL.Create(context.Background(), azblob.BlobHTTPHeaders{}, azblob.Metadata{}, azblob.BlobAccessConditions{}, azblob.BlobTagsMap{}, azblob.ClientProvidedKeyOptions{}) if err != nil { return err } writeFunc := func(data []byte) error { - _, writeErr := appendBlobURL.AppendBlock(context.Background(), bytes.NewReader(data), azblob.AppendBlobAccessConditions{}, nil) + _, writeErr := appendBlobURL.AppendBlock(context.Background(), bytes.NewReader(data), azblob.AppendBlobAccessConditions{}, nil, azblob.ClientProvidedKeyOptions{}) return writeErr } |
