Как получить текущую запись инструкции конвейера foreach, используя безболезненные сценарии?

Question

Я пытаюсь считать объекты JSON на основе флага. Для этого я создал два конвейера foreach, перебирающих мои объекты.

Я хочу подсчитать все объекты в массиве documents, для которых поле "count" установлено в true.

POST _ingest/pipeline/_simulate
{  
   "pipeline":{  
      "description":"...",
      "processors":[  
         {  
            "set":{  
               "field":"specific.docCount",
               "value":0
            }
         },
         {  
            "foreach":{  
               "field":"data.status.transactions",
               "processor":{  
                  "foreach":{  
                     "field":"_ingest._value.documents",
                     "processor":{  
                        "script":{  
                           "lang":"painless",
                           "inline":"if (ctx.count) ctx.specific.docCount += 1"
                        }
                     }
                  }
               }
            }
         }
      ]
   },
   "docs":[  
      {  
         "_source":{  
            "data":{  
               "status":{  
                  "transactions":[  
                     {  
                        "id":"123",
                        "documents":[  
                           {  
                              "count": true
                           },
                           {
                              "count": false
                           }
                        ]
                     }
                  ]
               }
            }
         }
      }
   ]
}

Я получаю следующую ошибку:

{
  "docs": [
    {
      "error": {
        "root_cause": [
          {
            "type": "exception",
            "reason": "java.lang.IllegalArgumentException: ScriptException[runtime error]; nested: NullPointerException;",
            "header": {
              "processor_type": "foreach"
            }
          }
        ],
        "type": "exception",
        "reason": "java.lang.IllegalArgumentException: ScriptException[runtime error]; nested: NullPointerException;",
        "caused_by": {
          "type": "illegal_argument_exception",
          "reason": "ScriptException[runtime error]; nested: NullPointerException;",
          "caused_by": {
            "type": "script_exception",
            "reason": "runtime error",
            "script_stack": [
              "if (ctx.count) ",
              "       ^---- HERE"
            ],
            "script": "if (ctx.count) ctx.stats.docCount += 1",
            "lang": "painless",
            "caused_by": {
              "type": "null_pointer_exception",
              "reason": null
            }
          }
        },
        "header": {
          "processor_type": "foreach"
        }
      }
    }
  ]
}

Этот foreach pipe документ предлагает использовать ctx для ссылки на документ Ingest, но я не уверен, как использовать это в моем случае.

Как я могу получить текущую "запись foreach" в моем безболезненном сценарии?

Answer 1

Я закончил все это безболезненным сценарием.

POST _ingest/pipeline/_simulate
{  
   "pipeline":{  
      "description":"...",
      "processors":[  
         {  
            "set":{  
               "field":"stats.docCount",
               "value":0
            }
         },
         {  
            "script":{  
               "lang":"painless",
               "inline":"def transactions = ctx.data.status.transactions; for (def transaction : transactions) {def documents = transaction.documents; for (def document : documents){if (document.count != null && document.count){ctx.stats.docCount += 1}}}"
            }
         }
      ]
   },
   "docs":[  
      {  
         "_source":{  
            "data":{  
               "status":{  
                  "transactions":[  
                     {  
                        "id":"123",
                        "documents":[  
                           {  
                              "count":true
                           },
                           {  
                              "count":false
                           }
                        ]
                     }
                  ]
               }
            }
         }
      },
      {  
         "_source":{  
            "data":{  
               "status":{  
                  "transactions":[  
                     {  
                        "id":"234",
                        "documents":[  
                           {  
                              "count":true
                           },
                           {  
                              "count":true
                           }
                        ]
                     }
                  ]
               }
            }
         }
      },
      {  
         "_source":{  
            "data":{  
               "status":{  
                  "transactions":[  
                     {  
                        "id":"345",
                        "documents":[  
                           {  

                           },
                           {  
                              "count":true
                           }
                        ]
                     }
                  ]
               }
            }
         }
      }
   ]
}

Выход:

{
  "docs": [
    {
      "doc": {
        "_id": "_id",
        "_index": "_index",
        "_type": "_type",
        "_source": {
          "data": {
            "status": {
              "transactions": [
                {
                  "documents": [
                    {
                      "count": true
                    },
                    {
                      "count": false
                    }
                  ],
                  "id": "123"
                }
              ]
            }
          },
          "stats": {
            "docCount": 1
          }
        },
        "_ingest": {
          "timestamp": "2018-11-14T13:46:29.963Z"
        }
      }
    },
    {
      "doc": {
        "_id": "_id",
        "_index": "_index",
        "_type": "_type",
        "_source": {
          "data": {
            "status": {
              "transactions": [
                {
                  "documents": [
                    {
                      "count": true
                    },
                    {
                      "count": true
                    }
                  ],
                  "id": "234"
                }
              ]
            }
          },
          "stats": {
            "docCount": 2
          }
        },
        "_ingest": {
          "timestamp": "2018-11-14T13:46:29.963Z"
        }
      }
    },
    {
      "doc": {
        "_id": "_id",
        "_index": "_index",
        "_type": "_type",
        "_source": {
          "data": {
            "status": {
              "transactions": [
                {
                  "documents": [
                    {},
                    {
                      "count": true
                    }
                  ],
                  "id": "345"
                }
              ]
            }
          },
          "stats": {
            "docCount": 1
          }
        },
        "_ingest": {
          "timestamp": "2018-11-14T13:46:29.963Z"
        }
      }
    }
  ]
}