將 AWS redshiftdataapiservice.GetStatementResultOutput 轉換為 JSON 或結構
我有一個 AWS Redshift Serverless 資料庫,我正在透過 AWS Go SDK 的 redshiftdataapiservice
查詢該資料庫。查詢和所有這些都有效,但記錄以難以使用/理解的格式傳回。
我的程式碼是這樣的:
import ( "fmt" "log" "time" "os" "context" "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/config" "github.com/aws/aws-sdk-go-v2/service/redshiftdata" "github.com/aws/aws-sdk-go-v2/service/redshiftdata/types" ) // Execute a Redshift query and return a result statement output func executeRedshiftQuery(sql string) (*redshiftdata.GetStatementResultOutput, error) { // Load the Shared AWS Configuration (~/.aws/config) cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithRegion(os.Getenv("AWS_REGION"))) if err != nil { return nil, err } // Create a service client redshiftclient := redshiftdata.NewFromConfig(cfg) execStmt, err := redshiftclient.ExecuteStatement(context.TODO(), &redshiftdata.ExecuteStatementInput{ WorkgroupName: aws.String(os.Getenv("WG_NAME")), Database: aws.String(os.Getenv("DB_NAME")), Sql: aws.String(sql), }) if err != nil { return nil, err } // wait for query to finish for { descStmt, err := redshiftclient.DescribeStatement(context.TODO(), &redshiftdata.DescribeStatementInput{ Id: execStmt.Id, }) if err != nil { return nil, err } // return an error if the query failed or aborted if descStmt.Status == types.StatusStringFailed || descStmt.Status == types.StatusStringAborted { err := errors.New("the Redshift query failed or was aborted") return nil, err } else if descStmt.Status != types.StatusStringFinished { time.Sleep(1 * time.Second) continue } break } // get the results resultStmt, err := redshiftclient.GetStatementResult(context.TODO(), &redshiftdata.GetStatementResultInput{ Id: execStmt.Id, }) if err != nil { return nil, err } return resultStmt, nil }
我發現 *Field
s 的二維陣列很難處理。我如何(最好是簡單地)將其映射到可用的 JSON,或者說類型結構數組?或者有沒有辦法從 Redshift 請求 JSON?如果可能的話,我想將所有這些完全保留在我的 Golang 應用程式中。
正確答案
我沒有找到官方方法,但下面的方法是透過建立列名稱到列值的對應片段,然後從那裡解組來運作。
// Extracts the column name from column metadata for a given column index func getColumnName(metadata []types.ColumnMetadata, index int) string { if index < len(metadata) { // We assume the metadata is in the same order as the columns in the record. // If the column name is not set or empty, we can fallback to a default naming convention. if metadata[index].Name != nil { return *metadata[index].Name } return fmt.Sprintf("column_%d", index) } // Fallback if the index is out of range of the metadata slice. return fmt.Sprintf("unknown_column_%d", index) } // Converts query results to JSON bytes for easy unmarshaling to structs func queryResultsToJSON(query_results *redshiftdata.GetStatementResultOutput) ([]byte, error) { // Convert the records to a slice of maps for JSON conversion var records []map[string]interface{} for _, row := range query_results.Records { record := make(map[string]interface{}) for idx, col := range row { // Use the column metadata to determine the name of the column columnName := getColumnName(query_results.ColumnMetadata, idx) // Check the type of the value and assign it to the record map var value interface{} switch v := col.(type) { case *types.FieldMemberBlobValue: value = v.Value case *types.FieldMemberBooleanValue: value = v.Value case *types.FieldMemberDoubleValue: value = v.Value case *types.FieldMemberIsNull: value = nil case *types.FieldMemberLongValue: value = v.Value case *types.FieldMemberStringValue: value = v.Value } record[columnName] = value } records = append(records, record) } // Marshal the records to JSON jsonBytes, err := json.Marshal(records) if err != nil { log.Error("failed to marshal records to JSON, " + err.Error()) return nil, err } return jsonBytes, nil }
以上是將 AWS redshiftdataapiservice.GetStatementResultOutput 轉換為 JSON 或結構的詳細內容。更多資訊請關注PHP中文網其他相關文章!

熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

Video Face Swap
使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

熱工具

記事本++7.3.1
好用且免費的程式碼編輯器

SublimeText3漢化版
中文版,非常好用

禪工作室 13.0.1
強大的PHP整合開發環境

Dreamweaver CS6
視覺化網頁開發工具

SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)

Golang在性能和可擴展性方面優於Python。 1)Golang的編譯型特性和高效並發模型使其在高並發場景下表現出色。 2)Python作為解釋型語言,執行速度較慢,但通過工具如Cython可優化性能。

Golang在並發性上優於C ,而C 在原始速度上優於Golang。 1)Golang通過goroutine和channel實現高效並發,適合處理大量並發任務。 2)C 通過編譯器優化和標準庫,提供接近硬件的高性能,適合需要極致優化的應用。

goimpactsdevelopmentpositationality throughspeed,效率和模擬性。 1)速度:gocompilesquicklyandrunseff,IdealforlargeProjects.2)效率:效率:ITScomprehenSevestAndardArdardArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdArdEcceSteral Depentencies,增強的Depleflovelmentimency.3)簡單性。

goisidealforbeginnersandsubableforforcloudnetworkservicesduetoitssimplicity,效率和concurrencyFeatures.1)installgromtheofficialwebsitealwebsiteandverifywith'.2)

Golang適合快速開發和並發場景,C 適用於需要極致性能和低級控制的場景。 1)Golang通過垃圾回收和並發機制提升性能,適合高並發Web服務開發。 2)C 通過手動內存管理和編譯器優化達到極致性能,適用於嵌入式系統開發。

Golang和Python各有优势:Golang适合高性能和并发编程,Python适用于数据科学和Web开发。Golang以其并发模型和高效性能著称,Python则以简洁语法和丰富库生态系统著称。

Golang和C 在性能上的差異主要體現在內存管理、編譯優化和運行時效率等方面。 1)Golang的垃圾回收機制方便但可能影響性能,2)C 的手動內存管理和編譯器優化在遞歸計算中表現更為高效。

C 更適合需要直接控制硬件資源和高性能優化的場景,而Golang更適合需要快速開發和高並發處理的場景。 1.C 的優勢在於其接近硬件的特性和高度的優化能力,適合遊戲開發等高性能需求。 2.Golang的優勢在於其簡潔的語法和天然的並發支持,適合高並發服務開發。
