func loginKinesis(awsAccessKey, awsSecretKey, region string) *kinesis.Kinesis {
    //初始化环境变量
    if (awsAccessKey == "") || (awsSecretKey == "") {
        awsAccessKey = "AAAAAACCCCCEEEEEEEEESSSSS"
        awsSecretKey = "AWSSSSSSSSSSSSKKKKKKKKKKKKKKKKYYYYYYYYYY"
    }
    err = os.Setenv("AWS_ACCESS_KEY", awsAccessKey)
    if err != nil {
        fmt.Println("ERROR:ACCESS_KEY SET----", err.Error())
    }
    err = os.Setenv("AWS_SECRET_KEY", awsSecretKey)
    if err != nil {
        fmt.Println("ERROR:SECRET_KEY SET----", err.Error())
    }
    // 从环境变量中获取accesskey和secretkey
    auth, err = kinesis.NewAuthFromEnv()
    if err != nil {
        fmt.Printf("Unable to retrieve authentication credentials from the environment: %v", err)
    }
    //认证登录
    ksi := kinesis.New(auth, region)
    return ksi
}

 

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-07-25
  • 2021-12-11
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2022-01-30
  • 2022-12-23
  • 2022-12-23
  • 2021-12-07
  • 2022-12-23
  • 2021-09-28
  • 2022-12-23
相关资源
相似解决方案