google-app-engine - 数据流作业内的默认数据存储实例

Question

我正在尝试在数据流作业中调用 Google 数据存储，但我得到了空实例

datastore = DatastoreOptions.getDefaultInstance().getService();

Answer 1

这可能是一个凭据问题。你能试试这个吗，

Credentials credentials = context.getPipelineOptions().as(GcpOptions.class).getGcpCredential();

Datastore datastore = DatastoreOptions.newBuilder().setCredentials(credentials).build().getService();