aws-sdk-go

    -1熱度

    1回答

    我正在使用aws-sdk-go for dynamodb。我需要從我的數據庫中收集一些項目。濾波條件爲設備ID:XYZ,時間> = 10和時間< = 20 時間爲我的分貝和設備ID排序鍵是主鍵。我知道我必須使用BETWEEN來實現我的目標。我的實現不成功,如下所示: var queryInput = &dynamodb.QueryInput{ TableName: aws.String(

    0熱度

    1回答

    我通過PutRecords發送數據給aws kinesis。所有的數據都發送成功。 但是有些記錄在消費者方面收到兩次。我檢查了發送的數據和收到的數據,它們是一樣的。 我覺得PutRecords會在沒有收到來自kinesis服務器的響應時重新發送數據(響應由於可怕的網絡站點而丟失)。但數據是由kinesis服務器接收的。 因此,我在消費者方面獲得了兩次相同的記錄。 我的假設是否正確?

    -2熱度

    1回答

    我是Go lang的初學者,我嘗試使用AWS在Go lang和Dynamodb之間建立連接,並使用Go lang編寫的API在dynamodb中插入數據。任何幫助,將不勝感激。 下面是什麼,我試圖做的代碼: package main import "fmt" \t import ( "github.com/aws/aws-sdk-go/aws" \t "githu

    0熱度

    2回答

    我以前使用過環境變量,它工作正常。 現在我正在將我的配置變量遷移到單個文件中,並且我具有包含從此文件加載的相應值的AWS_SECRET_ACCESS_KEY和AWS_ACCESS_KEY_ID變量。 我想這個代碼,但收到一個錯誤: creds := credentials.NewStaticCredentials("123", conf.AWS_SECRET_ACCESS_KEY, conf.AW

    3熱度

    2回答

    我有一個使用AWS-SDK-去談話dynamodb Go程序。依賴關係是暢銷的。去版本1.7.1。 aws-sdk-go版本1.6.24。該項目工程按預期在所有以下環境:從外殼 開發框(Arch Linux的)對我的dev的盒子運行 泊塢窗容器(泊塢窗1.13.1)從外殼 EC2實例(Ubuntu的16.04) 當我運行kubernetes泊塢窗容器(我在我的dev的盒子測試同一個),我收到以下錯

    2熱度

    3回答

    我想在aws-dynamodb中保存JSON響應,我正在使用aws-dynamodb-sdk。什麼我目前做的是: func (e *DB) saveToDynamodb(data map[string]interface{}){ params := &dynamodb.PutItemInput{ Item: map[string]*dynamodb.AttributeValue{

    4熱度

    1回答

    我正試圖將給定的數據流保存到S3兼容存儲中。 大小在流結束前是未知的,可以從5MB到500GB不等。 我嘗試了不同的可能性,但沒有找到比自己實現分片更好的解決方案。我最好的猜測是將一個固定大小的緩衝區填充到我的流中,並將其寫入S3。 有更好的解決方案嗎?也許這對我來說是透明的,而不是將整個流寫入內存? 的AWS-SDK-去自述有一個例子PROGRAMM從標準輸入提取數據,並將其寫入S3:https

    0熱度

    1回答

    我需要發送SNS推送通知給多個設備,使用aws-sdk-go庫傳遞設備令牌陣列。 創建端點: pl, err := svc.CreatePlatformEndpoint(&sns.CreatePlatformEndpointInput{ PlatformApplicationArn: aws.String(topic), Token: aws.String(n.DeviceTo

    0熱度

    1回答

    簽名URL時,簽名不匹配403錯誤我遵循了關於此問題https://github.com/aws/aws-sdk-go/issues/467的說明,其中明確記錄瞭如何爲PUT請求創建預簽名url。我們的目標是presign的URL,這樣我就可以直接在瀏覽器安全 密鑰和密碼上傳圖像是當然,我是通過SDK直接PutObject要求工作電流憑證 creds := credentials.NewStati

    1熱度

    1回答

    我有以下snippit代碼使用當前aws-sdk-go版本v1.7.9。 sess, _ := session.NewSession() s3client := s3.New(sess) location, err := s3client.GetBucketLocation(&s3.GetBucketLocationInput{Bucket: &bucket}) 我在調用GetBucket