如何用Java API将com.google.cloud.datastore.Key转换为com.google.datastore.v1.Key？

你遇到的「Invalid Protocol missing wire type」异常，是因为错误地把com.google.cloud.datastore.Key的toString()输出当成了Protobuf二进制数据解析——toString()返回的是可读的字符串格式，并非Protobuf的wire编码字节流，自然无法被parseFrom()正确解析。

正确的转换方式 #

Google Cloud Datastore的客户端库提供了原生的转换方法，直接调用Key对象的toPb()方法就能得到对应的com.google.datastore.v1.Key实例，无需手动解析字节流：

修改你代码中的转换逻辑部分：

if(keys.length > 0){
    int i = keys.length - 1;
    while(i >= 0){ // 原代码i>0会漏掉索引0的元素，建议修正
        com.google.cloud.datastore.Key cloudKey = keys[i].getKey();
        LOG.info("keyStream::::{}", cloudKey.toString()); // 修正日志参数占位符
        // 直接用toPb()完成转换
        com.google.datastore.v1.Key keyV1 = cloudKey.toPb();
        i--;
    }
}

补充说明 #

• 如果需要转换整个com.google.cloud.datastore.Entity到com.google.datastore.v1.Entity，同样可以调用entity.toPb()方法，这是官方支持的安全转换方式，避免手动处理Protobuf的编码细节。
• 确保你的Cloud Datastore客户端库版本与DataFlow依赖的Datastore V1版本兼容，避免因版本差异导致的转换问题。

内容的提问来源于stack exchange，提问作者Azar