使用uplink-Python创建一个新的storj存储桶。

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

Create a new storj bucket with uplink-Python

问题

我正在尝试使用uplink-python创建一个新的storj存储桶，有人知道这个错误吗？

谢谢

  1. class Storage:
  3.     def __init__(self, api_key: str, satellite: str, passphrase: str, email: str):
  4.         """
  5.             account Storj
  6.         """
  7.         self.api_key = api_key
  8.         self.satellite = satellite
  9.         self.email = email
  10.         self.passphrase = passphrase
  11.         self.uplink = Uplink()
  12.         self.config = Config()
  13.         self.access = self.uplink.config_request_access_with_passphrase(self.config,
  14.                                                                         self.satellite,
  15.                                                                         self.api_key,
  16.                                                                         self.passphrase)
  17.         self.project = self.access.open_project() <-- 打开项目
  19.     def create_bucket(self, mybucket: str):
  20.         """
  21.          创建一个存储桶，如果已存在则忽略错误
  22.         """
  23.         print(mybucket)
  24.         self.project.ensure_bucket(mybucket)
  26.     def get_bucket(self, mybucket: str):
  27.         """
  28.          验证存储桶
  29.         """
  30.         print(mybucket)
  31.         return self.project.stat_bucket(mybucket)
  33.     def close(self):
  34.         self.project.close()
  37. storage = Storage(api_key="zzz", satellite=".storj.io:7777", passphrase="passtest", mail="bucket@bucket.com")
  39. 验证旧的存储桶
  41. storage.get_bucket("demo01") # 运行正常
  43. 创建一个新的存储桶
  45. storage.create_bucket("Hello") # 内部错误
  48. 输出：
  50. >  File "../test/uplink/lib/python3.9/site-packages/uplink_python/project.py", line 121, in ensure_bucket
  51.     raise _storj_exception(bucket_result.error.contents.code,
  52. uplink_python.errors.InternalError: 'internal error'
  55. 121行
  57.     def ensure_bucket(self, bucket_name: str):
  58.         """
  59.         确保存储桶存在或创建一个新的存储桶。
  61.         当存储桶已存在时，返回一个有效的存储桶而不报错
  63.         参数
  64.         ----------
  65.         bucket_name : str
  67.         返回
  68.         -------
  69.         Bucket
  70.         """
  72.         #
  73.         # 声明相应的golang函数的参数和返回值类型
  74.         self.uplink.m_libuplink.uplink_ensure_bucket.argtypes = [ctypes.POINTER(_ProjectStruct),
  75.                                                                  ctypes.c_char_p]
  76.         self.uplink.m_libuplink.uplink_ensure_bucket.restype = _BucketResult
  77.         #
  78.         # 准备函数的输入
  79.         bucket_name_ptr = ctypes.c_char_p(bucket_name.encode('utf-8'))
  81.         # 通过调用导出的golang函数打开存储桶（如果不存在）
  82.         bucket_result = self.uplink.m_libuplink.uplink_ensure_bucket(self.project, bucket_name_ptr)
  83.         #
  84.         # 如果发生错误
  85.         if bool(bucket_result.error):
  86.             raise _storj_exception(bucket_result.error.contents.code,
  87.                                    bucket_result.error.contents.message.decode("utf-8"))
  88.         return self.uplink.bucket_from_result(bucket_result.bucket)
  90. "内部错误"的消息来自于"raise _storj_exception.."这一行
  92. 补充：
  93. 使用Web界面创建新的存储桶时没有错误
  95. 参考：
  96. https://storj-thirdparty.github.io/uplink-python/#/library?id=ensure_bucketbucket_name
  98. https://github.com/storj/uplink/blob/8da069b86063ee9671cc85cc44eaa6b8baf84b58/bucket.go#L97
英文:

I'm trying to create a new storj bucket with uplink-python
Does anyone know this error ?

Thank you

  1. class Storage:
  2. def __init__(self, api_key: str, satellite: str, passphrase: str, email: str):
  3. &quot;&quot;&quot;
  4. account Storj
  5. &quot;&quot;&quot;
  6. self.api_key = api_key
  7. self.satellite = satellite
  8. self.email = email
  9. self.passphrase = passphrase
  10. self.uplink = Uplink()
  11. self.config = Config()
  12. self.access = self.uplink.config_request_access_with_passphrase(self.config,
  13. self.satellite,
  14. self.api_key,
  15. self.passphrase)
  16. self.project = self.access.open_project() &lt;-- open the project
  17. def create_bucket(self, mybucket: str):
  18. &quot;&quot;&quot;
  19. Create un bucket and ingnores the error if it already exist
  20. &quot;&quot;&quot;
  21. print(mybucket)
  22. self.project.ensure_bucket(mybucket)
  23. def get_bucket(self, mybucket: str):
  24. &quot;&quot;&quot;
  25. verify bucket
  26. &quot;&quot;&quot;
  27. print(mybucket)
  28. return self.project.stat_bucket(mybucket)
  29. def close(self):
  30. self.project.close()
  31. storage = Storage(api_key=&quot;zzz&quot;, satellite=&quot;.storj.io:7777&quot;, passphrase=&quot;passtest&quot;, mail=&quot;bucket@bucket.com&quot;)

Verify the old bucket

  1. storage.get_bucket(&quot;demo01&quot;) # it&#39;s works

Create a new bucket

  1. storage.create_bucket(&quot;Hello&quot;) # internal error

output:

> File "../test/uplink/lib/python3.9/site-packages/uplink_python/project.py", line 121, in ensure_bucket
raise _storj_exception(bucket_result.error.contents.code,
uplink_python.errors.InternalError: 'internal error'

line 121

  1.     def ensure_bucket(self, bucket_name: str):
  2. &quot;&quot;&quot;
  3. function ensures that a bucket exists or creates a new one.
  4. When bucket already exists it returns a valid Bucket and no error
  5. Parameters
  6. ----------
  7. bucket_name : str
  8. Returns
  9. -------
  10. Bucket
  11. &quot;&quot;&quot;
  12. #
  13. # declare types of arguments and response of the corresponding golang function
  14. self.uplink.m_libuplink.uplink_ensure_bucket.argtypes = [ctypes.POINTER(_ProjectStruct),
  15. ctypes.c_char_p]
  16. self.uplink.m_libuplink.uplink_ensure_bucket.restype = _BucketResult
  17. #
  18. # prepare the input for the function
  19. bucket_name_ptr = ctypes.c_char_p(bucket_name.encode(&#39;utf-8&#39;))
  20. # open bucket if doesn&#39;t exist by calling the exported golang function
  21. bucket_result = self.uplink.m_libuplink.uplink_ensure_bucket(self.project, bucket_name_ptr)
  22. #
  23. # if error occurred
  24. if bool(bucket_result.error):
  25. raise _storj_exception(bucket_result.error.contents.code,
  26. bucket_result.error.contents.message.decode(&quot;utf-8&quot;))
  27. return self.uplink.bucket_from_result(bucket_result.bucket)

The "internal error" message comes from that "raise _storj_exception.."

add:
There are no error creating a new bucket with web interface

ref :
https://storj-thirdparty.github.io/uplink-python/#/library?id=ensure_bucketbucket_name

https://github.com/storj/uplink/blob/8da069b86063ee9671cc85cc44eaa6b8baf84b58/bucket.go#L97

答案1

得分: 0

已解决：
存储桶名称中的大写字母导致了内部错误...

将

  1. storage.create_bucket("Hello")

替换为

  1. storage.create_bucket("hello")

使用uplink-Python创建一个新的storj存储桶。

编辑：
这就是原因：
https://forum.storj.io/t/bucket-name-uppercase/20554/2?u=mike1

英文:

Solved:
an upper case letter in the bucket name causes the internal error...

replace

  1. storage.create_bucket(&quot;Hello&quot;)

with

  1. storage.create_bucket(&quot;hello&quot;)

使用uplink-Python创建一个新的storj存储桶。

EDIT:
that's why:
https://forum.storj.io/t/bucket-name-uppercase/20554/2?u=mike1

huangapple
  • 本文由 发表于 2022年12月2日 07:37:06
  • 转载请务必保留本文链接：https://go.coder-hub.com/74649328.html
  • amazon-s3
  • go
  • python
匿名

发表评论

匿名网友

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

确定