-
Notifications
You must be signed in to change notification settings - Fork 99
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
36 changed files
with
1,898 additions
and
2,001 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
File renamed without changes.
File renamed without changes.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,317 @@ | ||
| package lib | ||
|
|
||
| import ( | ||
| "encoding/xml" | ||
| "fmt" | ||
| "io/ioutil" | ||
| "os" | ||
| "strings" | ||
|
|
||
| oss "github.com/aliyun/aliyun-oss-go-sdk/oss" | ||
| ) | ||
|
|
||
| var specChineseBucketLifeCycle = SpecText{ | ||
| synopsisText: "设置、查询或者删除bucket的lifecycle配置", | ||
|
|
||
| paramText: "bucket_url local_xml_file [options]", | ||
|
|
||
| syntaxText: ` | ||
| ossutil lifecycle --method put oss://bucket local_xml_file [options] | ||
| ossutil lifecycle --method get oss://bucket [local_file] | ||
| ossuitl lifecycle --method delete oss://bucket | ||
| `, | ||
| detailHelpText: ` | ||
| lifecycle命令通过设置method选项值为put、get、delete,可以设置、查询或者删除bucket的lifecycle配置 | ||
| 用法: | ||
| 该命令有三种用法: | ||
| 1) ossutil lifecycle --method put oss://bucket local_xml_file [options] | ||
| 这个命令从配置文件local_xml_file中读取lifecycle配置，然后设置bucket的lifecycle规则 | ||
| 配置文件是一个xml格式的文件，举例如下 | ||
| <?xml version="1.0" encoding="UTF-8"?> | ||
| <LifecycleConfiguration> | ||
| <Rule> | ||
| <ID>RuleID</ID> | ||
| <Prefix>Prefix</Prefix> | ||
| <Status>Status</Status> | ||
| <Expiration> | ||
| <Days>Days</Days> | ||
| </Expiration> | ||
| <Transition> | ||
| <Days>Days</Days> | ||
| <StorageClass>StorageClass</StorageClass> | ||
| </Transition> | ||
| <AbortMultipartUpload> | ||
| <Days>Days</Days> | ||
| </AbortMultipartUpload> | ||
| </Rule> | ||
| </LifecycleConfiguration> | ||
| 2) ossutil lifecycle --method get oss://bucket [local_xml_file] | ||
| 这个命令查询bucket的lifecycle配置 | ||
| 如果输入参数local_xml_file，lifecycle配置将输出到该文件，否则输出到屏幕上 | ||
| 3) ossutil lifecycle --method delete oss://bucket | ||
| 这个命令删除bucket的lifecycle配置 | ||
| `, | ||
| sampleText: ` | ||
| 1) 设置bucket的lifecycle配置 | ||
| ossutil lifecycle --method put oss://bucket local_xml_file | ||
| 2) 查询bucket的lifecycle配置，结果输出到标准输出 | ||
| ossutil lifecycle --method get oss://bucket | ||
| 3) 查询bucket的lifecycle配置，结果输出到本地文件 | ||
| ossutil lifecycle --method get oss://bucket local_xml_file | ||
| 4) 删除bucket的lifecycle配置 | ||
| ossutil lifecycle --method delete oss://bucket | ||
| `, | ||
| } | ||
|
|
||
| var specEnglishBucketLifeCycle = SpecText{ | ||
| synopsisText: "Set、get or delete bucket lifecycle configuration", | ||
|
|
||
| paramText: "bucket_url lifecycle [options]", | ||
|
|
||
| syntaxText: ` | ||
| ossutil lifecycle --method put oss://bucket local_xml_file [options] | ||
| ossutil lifecycle --method get oss://bucket [local_xml_file] | ||
| ossuitl lifecycle --method delete oss://bucket | ||
| `, | ||
| detailHelpText: ` | ||
| lifecycle command can set、get and delete the lifecycle configuration of the oss bucket by | ||
| set method option value to put, get,delete | ||
| Usage: | ||
| There are three usages for this command: | ||
| 1) ossutil lifecycle --method put oss://bucket local_xml_file [options] | ||
| The command sets the lifecycle configuration of bucket from local file local_xml_file | ||
| the local_xml_file is xml format | ||
| The following is an example of the contents of local_xml_file | ||
| <?xml version="1.0" encoding="UTF-8"?> | ||
| <LifecycleConfiguration> | ||
| <Rule> | ||
| <ID>RuleID</ID> | ||
| <Prefix>Prefix</Prefix> | ||
| <Status>Status</Status> | ||
| <Expiration> | ||
| <Days>Days</Days> | ||
| </Expiration> | ||
| <Transition> | ||
| <Days>Days</Days> | ||
| <StorageClass>StorageClass</StorageClass> | ||
| </Transition> | ||
| <AbortMultipartUpload> | ||
| <Days>Days</Days> | ||
| </AbortMultipartUpload> | ||
| </Rule> | ||
| </LifecycleConfiguration> | ||
| 2) ossutil lifecycle --method get oss://bucket [local_xml_file] | ||
| The command gets the lifecycle configuration of bucket | ||
| If you input parameter local_xml_file,the configuration will be output to local_xml_file | ||
| If you don't input parameter local_xml_file,the configuration will be output to stdout | ||
| 3) ossutil lifecycle --method delete oss://bucket | ||
| The command deletes the lifecycle configuration of bucket | ||
| `, | ||
| sampleText: ` | ||
| 1) put bucket lifecycle | ||
| ossutil lifecycle --method put oss://bucket local_xml_file | ||
| 2) get lifecycle configuration to stdout | ||
| ossutil lifecycle --method get oss://bucket | ||
| 3) get lifecycle configuration to local file | ||
| ossutil lifecycle --method get oss://bucket local_xml_file | ||
| 5) delete lifecycle configuration | ||
| ossutil lifecycle --method delete oss://bucket | ||
| `, | ||
| } | ||
|
|
||
| type bucketLifeCycleOptionType struct { | ||
| bucketName string | ||
| } | ||
|
|
||
| type BucketLifeCycleCommand struct { | ||
| command Command | ||
| blOption bucketLifeCycleOptionType | ||
| } | ||
|
|
||
| var bucketLifeCycleCommand = BucketLifeCycleCommand{ | ||
| command: Command{ | ||
| name: "lifecycle", | ||
| nameAlias: []string{"lifecycle"}, | ||
| minArgc: 1, | ||
| maxArgc: 2, | ||
| specChinese: specChineseBucketLifeCycle, | ||
| specEnglish: specEnglishBucketLifeCycle, | ||
| group: GroupTypeNormalCommand, | ||
| validOptionNames: []string{ | ||
| OptionConfigFile, | ||
| OptionEndpoint, | ||
| OptionAccessKeyID, | ||
| OptionAccessKeySecret, | ||
| OptionSTSToken, | ||
| OptionLogLevel, | ||
| OptionMethod, | ||
| }, | ||
| }, | ||
| } | ||
|
|
||
| // function for FormatHelper interface | ||
| func (blc *BucketLifeCycleCommand) formatHelpForWhole() string { | ||
| return blc.command.formatHelpForWhole() | ||
| } | ||
|
|
||
| func (blc *BucketLifeCycleCommand) formatIndependHelp() string { | ||
| return blc.command.formatIndependHelp() | ||
| } | ||
|
|
||
| // Init simulate inheritance, and polymorphism | ||
| func (blc *BucketLifeCycleCommand) Init(args []string, options OptionMapType) error { | ||
| return blc.command.Init(args, options, blc) | ||
| } | ||
|
|
||
| // RunCommand simulate inheritance, and polymorphism | ||
| func (blc *BucketLifeCycleCommand) RunCommand() error { | ||
| strMethod, _ := GetString(OptionMethod, blc.command.options) | ||
| if strMethod == "" { | ||
| return fmt.Errorf("--method value is empty") | ||
| } | ||
|
|
||
| strMethod = strings.ToLower(strMethod) | ||
| if strMethod != "put" && strMethod != "get" && strMethod != "delete" { | ||
| return fmt.Errorf("--method value is not in the optional value:put|get|delete") | ||
| } | ||
|
|
||
| srcBucketUrL, err := GetCloudUrl(blc.command.args[0], "") | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| blc.blOption.bucketName = srcBucketUrL.bucket | ||
|
|
||
| if strMethod == "put" { | ||
| err = blc.PutBucketLifecycle() | ||
| } else if strMethod == "get" { | ||
| err = blc.GetBucketLifecycle() | ||
| } else if strMethod == "delete" { | ||
| err = blc.DeleteBucketLifecycle() | ||
| } | ||
| return err | ||
| } | ||
|
|
||
| func (blc *BucketLifeCycleCommand) PutBucketLifecycle() error { | ||
| if len(blc.command.args) < 2 { | ||
| return fmt.Errorf("put bucket lifecycle need at least 2 parameters,the local xml file is empty") | ||
| } | ||
|
|
||
| xmlFile := blc.command.args[1] | ||
| fileInfo, err := os.Stat(xmlFile) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if fileInfo.IsDir() { | ||
| return fmt.Errorf("%s is dir,not the expected file", xmlFile) | ||
| } | ||
|
|
||
| if fileInfo.Size() == 0 { | ||
| return fmt.Errorf("%s is empty file", xmlFile) | ||
| } | ||
|
|
||
| // parsing the xml file | ||
| file, err := os.Open(xmlFile) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer file.Close() | ||
| text, err := ioutil.ReadAll(file) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| rulesConfig := oss.LifecycleConfiguration{} | ||
| err = xml.Unmarshal(text, &rulesConfig) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // put bucket lifecycle | ||
| client, err := blc.command.ossClient(blc.blOption.bucketName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return client.SetBucketLifecycle(blc.blOption.bucketName, rulesConfig.Rules) | ||
| } | ||
|
|
||
| func (blc *BucketLifeCycleCommand) confirm(str string) bool { | ||
| var val string | ||
| fmt.Printf(getClearStr(fmt.Sprintf("bucket lifecycle: overwrite \"%s\"(y or N)? ", str))) | ||
| if _, err := fmt.Scanln(&val); err != nil || (strings.ToLower(val) != "yes" && strings.ToLower(val) != "y") { | ||
| return false | ||
| } | ||
| return true | ||
| } | ||
|
|
||
| func (blc *BucketLifeCycleCommand) GetBucketLifecycle() error { | ||
| client, err := blc.command.ossClient(blc.blOption.bucketName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| lifeCycleRes, err := client.GetBucketLifecycle(blc.blOption.bucketName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| output, err := xml.MarshalIndent(lifeCycleRes, " ", " ") | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| var outFile *os.File | ||
| if len(blc.command.args) >= 2 { | ||
| fileName := blc.command.args[1] | ||
| _, err = os.Stat(fileName) | ||
| if err == nil { | ||
| bConitnue := blc.confirm(fileName) | ||
| if !bConitnue { | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| outFile, err = os.OpenFile(fileName, os.O_CREATE|os.O_TRUNC|os.O_RDWR, 0660) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer outFile.Close() | ||
| } else { | ||
| outFile = os.Stdout | ||
| } | ||
|
|
||
| outFile.Write([]byte(xml.Header)) | ||
| outFile.Write(output) | ||
|
|
||
| fmt.Printf("\n\n") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (blc *BucketLifeCycleCommand) DeleteBucketLifecycle() error { | ||
| // delete bucket lifecycle | ||
| client, err := blc.command.ossClient(blc.blOption.bucketName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return client.DeleteBucketLifecycle(blc.blOption.bucketName) | ||
| } |
Oops, something went wrong.