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 }
