我如何使用数据存储区java客户端检索具有重复属性的嵌入式实体

Question

我使用AppEngine SDK的python API在数据存储区上创建实体，并且想要在Google Cloud Dataflow（Java）上检索它们。实体的结构是这样的：

• 实体
  • embedded_entity（ndb.StructuredProperty（重复= TRUE））
    • 名
    • 名
    • 名
    • 名

检索将是这样的，但我知道我错过了我提取数据的步骤。

static class EmbeddedStringExtractor extends DoFn<Entity, String> { 
    @Override 
    public void processElement(ProcessContext c) { 
    Map<String, Value> main_entity_map = DatastoreHelper.getPropertyMap(c.element()); 
    Entity embedded_entity = entity.get("embedded_entity").getEntityValue(); 
    // missing step 
    Map<String, Value> embedded_entity_map = DatastoreHelper.getPropertyMap(embedded_entity); 
    String some_string = DatastoreHelper.getString(embedded_entity_map.get("name")); 
    } 
} 

我将如何遍历所有重复的属性？

Answer 1

好吧，明白了。这是我如何启用它：

static class EmbeddedStringExtractor extends DoFn<Entity, String> { 
    @Override 
    public void processElement(ProcessContext c) { 
    Map<String, Value> main_entity_map = DatastoreHelper.getPropertyMap(c.element()); 
    List<Value> embedded_entity_values = entity.get("embedded_entity").getListValueList(); 

     for (Value embedded_entity_value: embedded_entity_values){ 
      Entity embedded_entity = embedded_entity_value.getEntityValue(); 
      Map<String, Value> embedded_map = DatastoreHelper.getPropertyMap(embedded_entity); 
      String embedded_name = DatastoreHelper.getString(embedded_map.get("name")); 
     } 

    // And then just c.output whatever you need. 

    } 
} 

只需要习惯Java API。