我正在运行一个在GCP存储桶中创建或更新对象的服务。也就是说,我的代码检查对象是否存在,如果存在,我的代码读取它,更新它,然后写回它。有时,我在尝试读取对象时会遇到异常。堆栈跟踪:at com.google.cloud.storage.Blob.getContent(Blob.java:455)
at com.google.cloud.storage.S
我正在使用Cloud Composer,它运行Apache Airflow,从Azure data Lake Gen2复制数据到云存储。我还不知道的是如何使用wasb和存储帐户密钥或SAS令牌连接到ADLS。我还没有找到任何例子来说明这个过程(连接到azure data lake)。 你能给我推荐一些我可能会遵循的示例代码吗?