fs.writeFile dans une promesse, des éléments asynchrones synchrones

J'ai besoin d'aide avec mon code. Je suis nouveau sur nodejs et ont beaucoup de mal avec elle.
Ce que j'essaie de faire:

  • 1)chercher un .txt avec les produits Amazon(ASIN)
  • 2)récupérer tous les produits avec le amazon-produit-api paquet
  • 3)enregistrer chaque produit dans un .fichier json

Mon code ne fonctionne pas. Je pense que j'ai foiré avec cette asynchrone-synchrone de trucs m'aider!

var amazon = require('amazon-product-api');
var fs = require('fs');

var client = amazon.createClient({
    awsId: "XXX",
    awsSecret: "XXX",
    awsTag: "888"
});

var array = fs.readFileSync('./test.txt').toString().split('\n');
for (var i = 1; i < array.length; i++) {
     var ASIN = array[i];

    return client.itemLookup({
            domain: 'webservices.amazon.de',
            responseGroup: 'Large',
            idType: 'ASIN',
            itemId: ASIN
        })
        .then(function(results) {
            fs.writeFile(ASIN + '.json', JSON.stringify(results), function(err) {
                if (err) {
                    console.log(err);
                } else {
                    console.log("JSON saved");
                }
            })

            return results;

        }).catch(function(err) {
            console.log(err);
        });
};

source d'informationauteur Markus Schmidlich

  1. 32

    Parce que fs.writefile est un traditionnel rappel asynchrone - vous besoin de suivre la promesse spec et de retourner une nouvelle promesse en l'enveloppant avec une détermination et le rejet de gestionnaire de la sorte:

    return new Promise(function(resolve, reject) {
    fs.writeFile("<filename.type>", data, '<file-encoding>', function(err) {
        if (err) reject(err);
        else resolve(data);
    });
});

    Donc, dans votre code, vous l'utilisez comme une sorte juste après votre appel à .then()

     .then(function(results) {
    return new Promise(function(resolve, reject) {
            fs.writeFile(ASIN + '.json', JSON.stringify(results), function(err) {
               if (err) reject(err);
               else resolve(data);
            });
    });
  }).then(function(results) {
       console.log("results here: " + results)
  }).catch(function(err) {
       console.log("error here: " + err);
  });
  2. 19

    dire

    const util = require('util')
const fs_writeFile = util.promisify(fs.writeFile)

    https://nodejs.org/api/util.html#util_util_promisify_original

    c'est moins sujette aux bugs que le haut-voté réponse

  3. 5

    Mise à jour Septembre 2017: fs-promise a été dépréciée en faveur de fs-extra.

    Je ne l'ai pas utilisé, mais vous pouvez regarder dans fs-promesse. C'est un nœud de module:

    Procurations tous async fs méthodes de les exposer comme des Promesses/A+ compatible
    promesses (quand, Q, etc). Passe tous les modes de synchronisation à travers des valeurs.

  4. 5

    Enfin, la dernière node.js version v10.3.0 a supporté nativement fs promesses.

    const fsPromises = require('fs').promises; //or require('fs/promises') in v10.0.0
fsPromises.writeFile(ASIN + '.json', JSON.stringify(results))
  .then(() => {
    console.log('JSON saved');
  })
  .catch(er => {
    console.log(er);
  });

    Vous pouvez consulter la documentation officielle pour plus de détails.
    https://nodejs.org/api/fs.html#fs_fs_promises_api

  5. 2
    const util = require('util')
const fs = require('fs');

const fs_writeFile = util.promisify(fs.writeFile)

fs_writeFile('message.txt', 'Hello Node.js')
    .catch((error) => {
        console.log(error)
    });
  6. -1

    Pour facile à utiliser asynchrone convertir tous rappel de la promesse utiliser une bibliothèque comme "bluebird" . 

          .then(function(results) {
                fs.writeFile(ASIN + '.json', JSON.stringify(results), function(err) {
                    if (err) {
                        console.log(err);
                    } else {
                        console.log("JSON saved");
                        return results;
                    }
                })


            }).catch(function(err) {
                console.log(err);
            });

    Essayez la solution avec la promesse (bluebird)

    var amazon = require('amazon-product-api');
var fs = require('fs');
var Promise = require('bluebird');

var client = amazon.createClient({
    awsId: "XXX",
    awsSecret: "XXX",
    awsTag: "888"
});


var array = fs.readFileSync('./test.txt').toString().split('\n');
Promise.map(array, function (ASIN) {
    client.itemLookup({
        domain: 'webservices.amazon.de',
        responseGroup: 'Large',
        idType: 'ASIN',
        itemId: ASIN
    }).then(function(results) {
        fs.writeFile(ASIN + '.json', JSON.stringify(results), function(err) {
            if (err) {
                console.log(err);
            } else {
                console.log("JSON saved");
                return results;
            }
        })
    }).catch(function(err) {
        console.log(err);
    });
});