MongoDB, обновления и контроль истечения срока действия документа

Я работаю над проектом node.js. Я пытаюсь понять, как работает MongoDB. Я получаю данные ежечасно через файл cron. Я хотел бы, чтобы были уникальные данные, поэтому я использую обновление вместо вставки. Это прекрасно работает. Я хотел бы добавить вариант, что срок действия данных истекает через три дня. Мне непонятно, как это сделать.

В псевдокоде:

Настройте Vars, URL-адреса, пару глобальных переменных, lineNr=1, end_index=#, включая databaseUrl.

   MongoClient.connect(databaseUrl, function(err, db) {
    assert.equal(null, err, "Database Connection Troubles: " + err);
 **** db.collection('XYZ_Collection').createIndex({"createdAt": 1},
            {expireAfterSeconds: 120}, function() {});   **** (update)

   s = fs.createReadStream(text_file_directory + 'master_index.txt')
        .pipe(es.split())
        .pipe(es.mapSync(function(line) { 
                s.pause();  // pause the readstream
                lineNr += 1;
                getContentFunction(line, s); 
                if (lineNr > end_index) {
                    s.end();
                }
        })
        .on('error', function() {
            console.log('Error while reading file.');
        })
        .on('end', function() {
            console.log('All done!');
        })
    );

    function getContentFunction(line, stream){ 
        (get content, format it, store it as flat JSON CleanedUpContent)
        var go = InsertContentToDB(db, CleanedUpContent, function() {
            stream.resume();
        });
    }  

    function InsertContentToDB(db, data, callback)   
            (expiration TTL code if placed here generates errors too..)             
            db.collection('XYZ_collection').update({
                    'ABC': data.abc,
                    'DEF': data.def)
                }, {
                    "createdAt": new Date(),
                    'ABC': data.abc,
                    'DEF': data.def,
                    'Content': data.blah_blah
                }, {
                    upsert: true
                },
                function(err, results) {
                    assert.equal(null, err, "MongoDB Troubles: " + err);
                    callback();
                });
    }

Таким образом, db.collection('').update() с двумя полями формирует составной индекс, чтобы обеспечить уникальность данных. upsert = true позволяет вставлять или обновлять по мере необходимости. Мои данные сильно разнятся. Некоторый контент уникален, другой контент является обновлением ранее представленного. Я думаю, что эта уникальная функция вставки или обновления работает правильно. Информация из... и здесь

Что я действительно хотел бы добавить, так это автоматическое истечение срока действия документов в коллекции. Я вижу много контента, но не могу понять, как это реализовать.

Если я попытаюсь

db.collection('XYZ_collection')
  .ensureIndex( { "createdAt": 1 }, 
                { expireAfterSeconds: 259200 } );   // three days 

Ошибка

/opt/rh/nodejs010/root/usr/lib/node_modules/mongodb/lib/mongodb/mongo_client.js:390 throw err ^ Ошибка: невозможно использовать writeConcern без предоставленного обратного вызова в Db.ensureIndex (/opt/rh/nodejs010 /root/usr/lib/node_modules/mongodb/lib/mongodb/db.js:1237:11) в Collection.ensureIndex (/opt/rh/nodejs010/root/usr/lib/node_modules/mongodb/lib/mongodb/коллекция .js:1037:11) в tempPrice (/var/lib/openshift/56d567467628e1717b000023/app-root/runtime/repo/get_options_prices.js:57:37) в /opt/rh/nodejs010/root/usr/lib/node_modules /mongodb/lib/mongodb/mongo_client.js:387:15 в процессе._tickCallback (node.js:442:13)

Если я попытаюсь использовать createIndex, я получу эту ошибку...

`TypeError: Cannot call method 'createIndex' of undefined`  

Обратите внимание, что база данных полностью пуста через db.XYZ_collection.drop() Так что да, я новичок в вещах Mongo. Кто-нибудь понял, что мне нужно сделать? Одно замечание: меня очень смущает что-то Я читал: в отношении того, что вы не можете создать индекс TTL, если индексированное поле уже используется другим индексом. Я думаю, что я в порядке, но это не ясно для меня.

Есть некоторые ограничения на выбор индекса TTL: вы не можете создать индекс TTL, если проиндексированное поле уже используется в другом индексе. index не может иметь несколько полей. индексированное поле должно быть типа Date bson

Как всегда, большое спасибо за вашу помощь.

Обновление: я добавил код createIndex выше. С пустым обратным вызовом он проходит без ошибок, но система TTL вообще не может удалить записи, вздох.