Aerospike Golang如何使用POLICY_KEY_SEND？

huangapple
go评论134阅读模式
英文:

Aerospike Golang how to use POLICY_KEY_SEND?

问题

我正在尝试使用Golang将带有主键（PK）的记录放入Aerospike数据库。默认策略会隐藏主键，所以我需要使用POLICY_KEY_SEND策略。我已经知道如何在PHP中使用该策略，但是我不知道如何在Golang的Aerospike库中使用它。以下是我的代码（Aerospike和PHP）：

Golang（不知道如何使用POLICY_KEY_SEND策略）：

  1. package main
  3. import "fmt"
  4. import aero "github.com/aerospike/aerospike-client-go"
  6. func main() {
  7. 	
  8. 	client, err := aero.NewClientWithPolicyAndHost(aero.NewClientPolicy(), 
  9. 		aero.NewHost("192.168.7.241", 3000), 
  10. 		aero.NewHost("192.168.7.243", 3000), 
  11. 		aero.NewHost("192.168.7.244", 3000), 
  12. 		aero.NewHost("192.168.7.245", 3000),
  13. 	)
  14. 	
  15. 	if err != nil {
  16. 		fmt.Println("AEROSPIKE CON ERR :", nil)
  17. 	} else {
  18. 		fmt.Println("SUCCESS AEROSPIKE")
  20. 		namespace := "test"
  21. 		setName := "test_golang_set"
  23. 		key, err := aero.NewKey(namespace, setName, "ASDF1234")
  24. 		if err != nil {
  25. 			fmt.Println("AEROSPIKE KEY ERR :", nil)
  26. 		} else {
  27. 			// define some bins
  28. 			bins := aero.BinMap{
  29. 				"game"  : "P4", // you can pass any supported type as bin value
  30. 				"genre" : "RPG",
  31. 				"price" : 59.9,
  32. 			}
  34. 			writePolicy := aero.NewWritePolicy(0, 0)
  35. 			err = client.Put(writePolicy, key, bins)
  36. 			
  37. 			if err != nil {
  38. 				fmt.Println("AEROSPIKE PUT ERR :", nil)
  39. 			} else {
  40. 				fmt.Println("AEROSPIKE PUT SUCCESS")
  41. 			}
  42. 		}
  43. 	}
  44. }

PHP（使用POLICY_KEY_SEND策略）：

  1. <?php
  3. /*连接相关的代码*/
  5. $name_space = "test";
  6. $sets = "test_golang_set";
  7. $pk_sets = "HIJK4869";
  8. $key = $aeroDB->initKey($name_space, $sets, $pk_sets);
  10. $option = [
  11.     Aerospike::OPT_POLICY_KEY => Aerospike::POLICY_KEY_SEND
  12. ];
  14. $bins = [
  15.     'game'   => 'ELDEN RING',
  16.     'genre'   => 'Relaxing',
  17.     'price'    => 59.9
  18. ];
  20. $putStatus = $aeroDB->put($key, $bins, 0, $option);
  22. if ($putStatus == Aerospike::OK) {
  23.     echo "OK";
  24. } else {
  25.     echo "ERR";
  26. }

这是结果的示例，最后两条记录是由Golang生成的（因为没有使用POLICY_KEY_SEND策略，所以主键未显示），第一条记录是由PHP生成的（因为使用了POLICY_KEY_SEND策略，所以主键显示）：

  1. aql> select * from test.test_golang_set
  2. +------------+--------------+------------+-------+
  3. | PK         | game         | genre      | price |
  4. +------------+--------------+------------+-------+
  5. | "HIJK4869" | "ELDEN RING" | "Relaxing" | 59.9  |
  6. |            | "P5"         | "RPG"      | 59.9  |
  7. |            | "P4"         | "RPG"      | 59.9  |
  8. +------------+--------------+------------+-------+
  9. 3 rows in set (0.508 secs)

注意：我使用的是这个Golang Aerospike库：https://github.com/aerospike/aerospike-client-go

英文:

Im trying to put a record with PK using golang, the default policy prevent PK to shows so i need to use policy POLICY_KEY_SEND. im able to put this policy using PHP but i have no clue how to use it in golang aerospike library, this is my code (Aerospike and PHP)

Golang (no clue how to put policy POLICY_KEY_SEND)

  1. package main
  3. import &quot;fmt&quot;
  4. import aero &quot;github.com/aerospike/aerospike-client-go&quot;
  6. func main() {
  7. 	
  8. 	client, err := aero.NewClientWithPolicyAndHost(aero.NewClientPolicy(), 
  9. 		aero.NewHost(&quot;192.168.7.241&quot;, 3000), 
  10. 		aero.NewHost(&quot;192.168.7.243&quot;, 3000), 
  11. 		aero.NewHost(&quot;192.168.7.244&quot;, 3000), 
  12. 		aero.NewHost(&quot;192.168.7.245&quot;, 3000),
  13. 	)
  14. 	
  15. 	if err != nil {
  16. 		fmt.Println(&quot;AEROSPIKE CON ERR :&quot;,nil)
  17. 	} else {
  18. 		fmt.Println(&quot;SUCCESS AEROSPIKE&quot;)
  20. 		namespace := &quot;test&quot;
  21. 		setName := &quot;test_golang_set&quot;
  23. 		key,err := aero.NewKey(namespace,setName,&quot;ASDF1234&quot;)
  24. 		if err != nil {
  25. 			fmt.Println(&quot;AEROSPIKE KEY ERR :&quot;,nil)
  26. 		} else {
  27. 			// define some bins
  28. 			bins := aero.BinMap{
  29. 				&quot;game&quot;  : &quot;P4&quot;, // you can pass any supported type as bin value
  30. 				&quot;genre&quot; : &quot;RPG&quot;,
  31. 				&quot;price&quot; : 59.9,
  32. 			}
  34. 			writePolicy := aero.NewWritePolicy(0, 0)
  35. 			err = client.Put(writePolicy, key, bins)
  36. 			
  37. 			if err != nil {
  38. 				fmt.Println(&quot;AEROSPIKE PUT ERR :&quot;,nil)
  39. 			} else {
  40. 				fmt.Println(&quot;AEROSPIKE PUT SUCCESS&quot;)
  41. 			}
  42. 		}
  43. 	}
  44. }

PHP (using POLICY_KEY_SEND)

  1. &lt;?php
  3. /*blablah connection stuff*/
  5. $name_space = &quot;test&quot;;
  6. $sets  = &quot;test_golang_set&quot;;
  7. $pk_sets = &quot;HIJK4869&quot;;
  8. $key = $aeroDB-&gt;initKey($name_space,$sets,$pk_sets);
  10. $option = [
  11.     Aerospike::OPT_POLICY_KEY =&gt; Aerospike::POLICY_KEY_SEND
  12. ];
  14. $bins = [
  15.     &#39;game&#39;   =&gt; &#39;ELDEN RING&#39;,
  16.     &#39;genre&#39;   =&gt; &#39;Relaxing&#39;,
  17.     &#39;price&#39;    =&gt; 59.9
  18. ];
  20. $putStatus = $aeroDB-&gt;put($key,$bins,0,$option);
  22. if($putStatus == Aerospike::OK) {
  23.     echo &quot;OK&quot;;
  24. } else {
  25.     echo &quot;ERR&quot;;
  26. }

this is sample of result, two last records generated by Golang (PK not shown because not using POLICY_KEY_SEND) , the first record by PHP (PK shown, because of POLICY_KEY_SEND) :

  1. aql&gt; select * from test.test_golang_set
  2. +------------+--------------+------------+-------+
  3. | PK         | game         | genre      | price |
  4. +------------+--------------+------------+-------+
  5. | &quot;HIJK4869&quot; | &quot;ELDEN RING&quot; | &quot;Relaxing&quot; | 59.9  |
  6. |            | &quot;P5&quot;         | &quot;RPG&quot;      | 59.9  |
  7. |            | &quot;P4&quot;         | &quot;RPG&quot;      | 59.9  |
  8. +------------+--------------+------------+-------+
  9. 3 rows in set (0.508 secs)

ps : im using this golang aerospike : https://github.com/aerospike/aerospike-client-go

答案1

得分: 4

尝试添加以下内容：

  1. writePolicy.SendKey = true

在调用之前：

  1. err = client.Put(writePolicy, key, bins)

根据 Aerospike Go 客户端文档：
SendKey 选项是 BasePolicy 的一部分（默认为 SendKey = false），它是 WritePolicy 的基本策略。

https://pkg.go.dev/github.com/aerospike/aerospike-client-go#BasePolicy
https://pkg.go.dev/github.com/aerospike/aerospike-client-go#WritePolicy

英文:

Try adding:

  1. writePolicy.SendKey = true

before calling:

  1. err = client.Put(writePolicy, key, bins)

According to Aerospike Go Client documentation:
SendKey option is a part of BasePolicy (default is SendKey = false) which is a base policy of WritePolicy.

https://pkg.go.dev/github.com/aerospike/aerospike-client-go#BasePolicy
https://pkg.go.dev/github.com/aerospike/aerospike-client-go#WritePolicy

huangapple
  • 本文由 发表于 2022年4月11日 15:57:53
  • 转载请务必保留本文链接：https://go.coder-hub.com/71824413.html
  • aerospike
  • go
  • php
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定