如何将 mongoDB 查询转换为 PHP？

Question

我的查询在 mongodb 中运行并正确生成输出。但是我尝试使用 php 运行相同的查询然后它给出了以下错误

Array
    (
        [ok] => 0
        [errmsg] => A pipeline stage specification object must contain exactly one field.
        [code] => 16435
    )

以下是我的 MongoDB 查询

db.sample_coll.aggregate(
{
  $unwind: {
        path:"$KeyValues", 
        includeArrayIndex:"arrayIndex", 
        preserveNullAndEmptyArrays:true 
    }
},
{
  $project: {
        timestamp:{ 
          "$add":["$EventTS",{"$multiply":[60000,"$arrayIndex"]}] 
        } ,
        "InputVolt":"$KeyValues.InputVolt", 
        arrayIndex:1
        }
},
{
  $match: {
    $and: [ 
        {InputVolt: {$ne: null}}
    ]
  }
}
); 

上面的查询是用php转换的

$pipeline = array(
            array('$unwind' => 
                    array( 'path' => '$KeyValues'),
                    array( 'includeArrayIndex' => 'arrayIndex' ), 
                    array( 'preserveNullAndEmptyArrays' => 'true' )
            ),
            array(
                '$project' => array(
                    'timestamp' => array(
                        '$add' => array(
                            '$EventTS',
                            array('$multiply' => array( 60000, '$arrayIndex' )) 
                        )
                    ),
                    array( 'InputVolt' => array( '$KeyValues', 'InputVolt'   ) ) ,
                    array('arrayIndex' => 1)
                )
            ),
            array(
                '$match' => array(
                    '$and' => array(
                        array('InputVolt' => array('$ne' => null )),
                    )
                )
            )

);
$result = $collection->aggregate($pipeline);

请帮助解决此问题。 提前致谢

Answer 1

您在 PHP 中的管道：

$pipeline = array(
        array('$unwind' => array(
            'path' => '$KeyValues',
            'includeArrayIndex' => 'arrayIndex',
            'preserveNullAndEmptyArrays' => true
        )),
        array('$project' => array(
            'timestamp' => array(
                '$add' => array('$EventTS', array('$multiply' => array(60000, '$arrayIndex')))
            ),
            'InputVolt' => '$KeyValues.InputVolt',
            'arrayIndex' => 1
        )),
        array('$match' => array(
            'InputVolt' => array('$ne' => null)
        ))
    );