{"id":685,"date":"2023-04-30T20:47:58","date_gmt":"2023-04-30T11:47:58","guid":{"rendered":"https:\/\/sheltie-garage.xyz\/tech\/?p=685"},"modified":"2023-04-30T20:48:00","modified_gmt":"2023-04-30T11:48:00","slug":"go%e3%81%8b%e3%82%89opensearch%e3%82%92%e5%88%a9%e7%94%a8%e3%81%97%e3%81%a6%e3%81%bf%e3%82%8b","status":"publish","type":"post","link":"https:\/\/sheltie-garage.xyz\/tech\/2023\/04\/go%e3%81%8b%e3%82%89opensearch%e3%82%92%e5%88%a9%e7%94%a8%e3%81%97%e3%81%a6%e3%81%bf%e3%82%8b\/","title":{"rendered":"Go\u304b\u3089OpenSearch\u3092\u5229\u7528\u3057\u3066\u307f\u308b"},"content":{"rendered":"\n

OpenSearch\u3092\u5229\u7528\u3059\u308b\u5834\u5408\u3001\u4f55\u304b\u3057\u3089\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u304b\u3089\u5229\u7528\u3059\u308b\u3053\u3068\u306b\u3042\u308b\u304b\u3068\u601d\u3044\u307e\u3059\u3002
\u4eca\u56de\u306fGo\u304b\u3089OpenSearch\u3092\u5229\u7528\u3057\u3066\u307f\u3088\u3046\u3068\u601d\u3044\u307e\u3059\u3002<\/p>\n\n\n\n

\u3068\u3044\u3063\u3066\u3082\u3001OpenSearch\u516c\u5f0f\u306b\u4e00\u901a\u308a\u306e\u30b5\u30f3\u30d7\u30eb\u304c\u7528\u610f\u3055\u308c\u3066\u3044\u308b\u305f\u3081\u3001\u8a18\u8f09\u3055\u308c\u3066\u3044\u308b\u65b9\u6cd5\u306b\u3066\u5b9f\u88c5\u3057\u307e\u3059\u3002<\/p>\n\n\n\n

\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u306f\u3053\u3061\u3089\u3067\u3059
https:\/\/opensearch.org\/docs\/latest\/clients\/go\/<\/a><\/p>\n\n\n\n

\u65e9\u901f\u30b3\u30fc\u30c9<\/h2>\n\n\n\n

\u516c\u5f0f\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u3092\u6d41\u7528\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n\n\n\n

package main\n\nimport (\n\t"context"\n\t"crypto\/tls"\n\t"fmt"\n\t"net\/http"\n\t"os"\n\t"strings"\n\n\topensearch "github.com\/opensearch-project\/opensearch-go"\n\topensearchapi "github.com\/opensearch-project\/opensearch-go\/opensearchapi"\n)\n\nconst IndexName = "go-test-index1"\n\nfunc main() {\n\t\/\/ Initialize the client with SSL\/TLS enabled.\n\tclient, err := opensearch.NewClient(opensearch.Config{\n\t\tTransport: &http.Transport{\n\t\t\tTLSClientConfig: &tls.Config{InsecureSkipVerify: true},\n\t\t},\n\t\tAddresses: []string{"https:\/\/localhost:9200"},\n\t\tUsername:  "admin", \/\/ For testing only. Don't store credentials in code.\n\t\tPassword:  "admin",\n\t})\n\tif err != nil {\n\t\tfmt.Println("cannot initialize", err)\n\t\tos.Exit(1)\n\t}\n\n\t\/\/ Print OpenSearch version information on console.\n\tfmt.Println(client.Info())\n\n\t\/\/ Define index settings.\n\tsettings := strings.NewReader(`{\n     'settings': {\n       'index': {\n            'number_of_shards': 1,\n            'number_of_replicas': 2\n            }\n          }\n     }`)\n\n\t\/\/ Create an index with non-default settings.\n\tres := opensearchapi.IndicesCreateRequest{\n\t\tIndex: IndexName,\n\t\tBody:  settings,\n\t}\n\tfmt.Println("Creating index")\n\tfmt.Println(res)\n\n\t\/\/ Add a document to the index.\n\tdocument := strings.NewReader(`{\n        "title": "Moneyball",\n        "director": "Bennett Miller",\n        "year": "2011"\n    }`)\n\n\tdocId := "1"\n\treq := opensearchapi.IndexRequest{\n\t\tIndex:      IndexName,\n\t\tDocumentID: docId,\n\t\tBody:       document,\n\t}\n\tinsertResponse, err := req.Do(context.Background(), client)\n\tif err != nil {\n\t\tfmt.Println("failed to insert document ", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Inserting a document")\n\tfmt.Println(insertResponse)\n\tdefer insertResponse.Body.Close()\n\n\t\/\/ Perform bulk operations.\n\tblk, err := client.Bulk(\n\t\tstrings.NewReader(`\n    { "index" : { "_index" : "go-test-index1", "_id" : "2" } }\n    { "title" : "Interstellar", "director" : "Christopher Nolan", "year" : "2014"}\n    { "create" : { "_index" : "go-test-index1", "_id" : "3" } }\n    { "title" : "Star Trek Beyond", "director" : "Justin Lin", "year" : "2015"}\n    { "update" : {"_id" : "3", "_index" : "go-test-index1" } }\n    { "doc" : {"year" : "2016"} }\n`),\n\t)\n\n\tif err != nil {\n\t\tfmt.Println("failed to perform bulk operations", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Performing bulk operations")\n\tfmt.Println(blk)\n\n\t\/\/ Search for the document.\n\tcontent := strings.NewReader(`{\n       "size": 5,\n       "query": {\n           "multi_match": {\n           "query": "miller",\n           "fields": ["title^2", "director"]\n           }\n      }\n    }`)\n\n\tsearch := opensearchapi.SearchRequest{\n\t\tIndex: []string{IndexName},\n\t\tBody:  content,\n\t}\n\n\tsearchResponse, err := search.Do(context.Background(), client)\n\tif err != nil {\n\t\tfmt.Println("failed to search document ", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Searching for a document")\n\tfmt.Println(searchResponse)\n\tdefer searchResponse.Body.Close()\n\n\t\/\/ Delete the document.\n\tdelete := opensearchapi.DeleteRequest{\n\t\tIndex:      IndexName,\n\t\tDocumentID: docId,\n\t}\n\n\tdeleteResponse, err := delete.Do(context.Background(), client)\n\tif err != nil {\n\t\tfmt.Println("failed to delete document ", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Deleting a document")\n\tfmt.Println(deleteResponse)\n\tdefer deleteResponse.Body.Close()\n\n\t\/\/ Delete the previously created index.\n\tdeleteIndex := opensearchapi.IndicesDeleteRequest{\n\t\tIndex: []string{IndexName},\n\t}\n\n\tdeleteIndexResponse, err := deleteIndex.Do(context.Background(), client)\n\tif err != nil {\n\t\tfmt.Println("failed to delete index ", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Deleting the index")\n\tfmt.Println(deleteIndexResponse)\n\tdefer deleteIndexResponse.Body.Close()\n}\n<\/code><\/pre><\/div>\n\n\n\n
\u4e0a\u8a18\u3092\u5b9f\u884c\u3059\u308b\u3068\u3001\u4ee5\u4e0b\u306e\u3088\u3046\u306a\u5b9f\u884c\u7d50\u679c\u304c\u5f97\u3089\u308c\u307e\u3059\u3002<\/p>\n\n\n\n
\"\"<\/figure>\n\n\n\n
\u30a4\u30f3\u30c7\u30c3\u30af\u30b9\u4f5c\u6210\u304b\u3089\u30c7\u30fc\u30bf\u306e\u8ffd\u52a0\u3001\u691c\u7d22\u3001\u305d\u3057\u3066\u30a4\u30f3\u30c7\u30c3\u30af\u30b9\u524a\u9664\u307e\u3067\u4e00\u9023\u306e\u6d41\u308c\u304cgo\u304b\u3089\u884c\u3046\u3053\u3068\u304c\u3067\u304d\u307e\u3059\u3002
\u4f7f\u3044\u65b9\u3082\u6bd4\u8f03\u7684\u30b7\u30f3\u30d7\u30eb\u3067\u3059\u306d<\/p>\n\n\n\n
\u30b5\u30f3\u30d7\u30eb\u30c7\u30fc\u30bf\u306b\u5bfe\u3057\u3066\u691c\u7d22\u3092\u304b\u3051\u3066\u307f\u308b<\/h2>\n\n\n\n
\u6b21\u306fOpenSearch\u306e\u30b5\u30f3\u30d7\u30eb\u30c7\u30fc\u30bf\u300copensearch_dashboards_sample_data_ecommerce\u300d\u306b\u5bfe\u3057\u3066\u691c\u7d22\u3092\u884c\u3063\u3066\u307f\u307e\u3059\u3002<\/p>\n\n\n\n
package main\n\nimport (\n\t"context"\n\t"crypto\/tls"\n\t"fmt"\n\t"net\/http"\n\t"os"\n\t"strings"\n\n\topensearch "github.com\/opensearch-project\/opensearch-go"\n\topensearchapi "github.com\/opensearch-project\/opensearch-go\/opensearchapi"\n)\n\nconst IndexName = "opensearch_dashboards_sample_data_ecommerce"\n\nfunc main() {\n\t\/\/ Initialize the client with SSL\/TLS enabled.\n\tclient, err := opensearch.NewClient(opensearch.Config{\n\t\tTransport: &http.Transport{\n\t\t\tTLSClientConfig: &tls.Config{InsecureSkipVerify: true},\n\t\t},\n\t\tAddresses: []string{"https:\/\/localhost:9200"},\n\t\tUsername:  "admin", \/\/ For testing only. Don't store credentials in code.\n\t\tPassword:  "admin",\n\t})\n\tif err != nil {\n\t\tfmt.Println("cannot initialize", err)\n\t\tos.Exit(1)\n\t}\n\n\t\/\/ Print OpenSearch version information on console.\n\tfmt.Println(client.Info())\n\n\t\/\/ Search for the document.\n\tcontent := strings.NewReader(`{\n       "size": 5,\n       "query": {\n           "match": {\n\t\t\t"customer_full_name" : "Mary"\n           }\n      }\n    }`)\n\n\tsearch := opensearchapi.SearchRequest{\n\t\tIndex: []string{IndexName},\n\t\tBody:  content,\n\t}\n\n\tsearchResponse, err := search.Do(context.Background(), client)\n\tif err != nil {\n\t\tfmt.Println("failed to search document ", err)\n\t\tos.Exit(1)\n\t}\n\tfmt.Println("Searching for a document")\n\tfmt.Println(searchResponse)\n\tdefer searchResponse.Body.Close()\n\n}\n<\/code><\/pre><\/div>\n\n\n\n
\u691c\u7d22\u3060\u3051\u306a\u3089\u3053\u308c\u3060\u3051\u3067\u5b9f\u884c\u3067\u304d\u307e\u3059\u3002
\u30b5\u30f3\u30d7\u30eb\u30c7\u30fc\u30bf\u306b\u5bfe\u3057\u3066\u3001\u9867\u5ba2\u540d\u304c\u300cMary\u300d\u3092\u542b\u3080\u30c7\u30fc\u30bf\u3092\u691c\u7d22\u3057\u3066\u3044\u307e\u3059\u3002
\u5b9f\u884c\u7d50\u679c\u306f\u4ee5\u4e0b\u306e\u901a\u308a\u3002<\/p>\n\n\n\n
\"\"<\/figure>\n\n\n\n
\u601d\u3063\u305f\u3088\u308a\u30c7\u30fc\u30bf\u304c\u305f\u304f\u3055\u3093\u5e30\u3063\u3066\u304d\u305f\u305f\u3081(154\u4ef6)\u3001\u3059\u3079\u3066\u306e\u7d50\u679c\u306f\u8f09\u305b\u3066\u3044\u307e\u305b\u3093\u304c\u3001JSON\u5f62\u5f0f\u3067\u30c7\u30fc\u30bf\u304c\u8fd4\u3063\u3066\u304d\u307e\u3057\u305f\u3002
\u3053\u308c\u306a\u3089\u3001json.Unmarshal\u3067\u69cb\u9020\u4f53\u306b\u5909\u63db\u3059\u308b\u3082\u306e\u7c21\u5358\u306b\u3067\u304d\u305d\u3046\u3067\u3059\u3002<\/p>\n\n\n\n
\u305f\u3060\u30af\u30a8\u30ea\u306e\u90e8\u5206\u306fJSON\u5f62\u5f0f\u306e\u6587\u5b57\u5217\u3067\u6e21\u3059\u5fc5\u8981\u304c\u3042\u308b\u306e\u3067\u3001\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u30af\u30a8\u30ea\u3092\u7d44\u307f\u7acb\u3066\u308b\u306e\u304c\u5c11\u3057\u5927\u5909\u305d\u3046\u3067\u3059\u3002
\u5225\u9014\u3001\u30d8\u30eb\u30d1\u30fc\u306e\u3088\u3046\u306a\u4ed5\u7d44\u307f\u304c\u7121\u3044\u304b\u3001\u8abf\u3079\u3066\u307f\u308b\u3064\u3082\u308a\u3067\u3059\u3002<\/p>\n\n\n
\n\t
\n\t\t
\n\t\t\t\t\t\t\t<\/a>\t\t\t\t\t<\/div>\n\t\t
\n\t\t\t
\n\t\t\t\t\t\t\t\t\tElastic Stack\u5b9f\u8df5\u30ac\u30a4\u30c9[Elasticsearch\/Kibana\u7de8]\u3010\u96fb\u5b50\u66f8\u7c4d\u3011[ \u60e3\u9053 \u54f2\u4e5f ]<\/a>\t\t\t\t\t\t\t<\/div>\n\t\t\t
\n\t\t\t\t\t\t\t
created by Rinker<\/a><\/div>\n\t\t\t\t\t\t\t\t\t\t
\n\t\t\t\t\t\t\t\u00a53,300<\/span>\n\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t(2026\/04\/21 22:21:13\u6642\u70b9 \u697d\u5929\u5e02\u5834\u8abf\u3079-<\/span>\u8a73\u7d30)<\/span>\n\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t\t<\/div>\n\t\t\t\t\t\t<\/div>\n\t\t\t\t\t\t