Browse Source

add filer replication to google cloud storage

pull/747/head
Chris Lu 6 years ago
parent
commit
84d4a2c8a0
  1. 10
      weed/command/scaffold.go
  2. 5
      weed/replication/sink/gcssink/gcs_sink.go

10
weed/command/scaffold.go

@ -179,7 +179,7 @@ ttlSec = 0
[sink.s3]
# experimental
# See https://docs.aws.amazon.com/sdk-for-go/v1/developer-guide/sessions.html
# read credentials doc at https://docs.aws.amazon.com/sdk-for-go/v1/developer-guide/sessions.html
# default loads credentials from the shared credentials file (~/.aws/credentials).
enabled = false
aws_access_key_id = "" # if empty, loads from the shared credentials file (~/.aws/credentials).
@ -189,13 +189,11 @@ bucket = "your_bucket_name" # an existing bucket
directory = "" # destination directory (do not prefix or suffix with "/")
[sink.google_cloud_storage]
# experimental
# see https://cloud.google.com/docs/authentication/getting-started
# read credentials doc at https://cloud.google.com/docs/authentication/getting-started
enabled = false
google_application_credentials = "/path/to/x.json" # path to json credential file
projectId = "your_project_id"
bucket = "your_bucket_name" # an existing bucket
directory = "/" # destination directory
bucket = "your_bucket_seaweedfs" # an existing bucket
directory = "/" # destination directory
`
)

5
weed/replication/sink/gcssink/gcs_sink.go

@ -17,7 +17,6 @@ import (
type GcsSink struct {
client *storage.Client
projectId string
bucket string
dir string
filerSource *source.FilerSource
@ -38,7 +37,6 @@ func (g *GcsSink) GetSinkToDirectory() string {
func (g *GcsSink) Initialize(configuration util.Configuration) error {
return g.initialize(
configuration.GetString("google_application_credentials"),
configuration.GetString("projectId"),
configuration.GetString("bucket"),
configuration.GetString("directory"),
)
@ -48,8 +46,7 @@ func (g *GcsSink) SetSourceFiler(s *source.FilerSource) {
g.filerSource = s
}
func (g *GcsSink) initialize(google_application_credentials, projectId, bucketName, dir string) (error) {
g.projectId = projectId
func (g *GcsSink) initialize(google_application_credentials, bucketName, dir string) (error) {
g.bucket = bucketName
g.dir = dir

Loading…
Cancel
Save