Exécuter plusieurs jobs de requête BigQuery en parallèle
Restez organisé à l'aide des collections
Enregistrez et classez les contenus selon vos préférences.
Exécute plusieurs requêtes BigQuery en parallèle, ce qui améliore les performances par rapport à l'exécution des requêtes en série, les unes après les autres.
En savoir plus
Pour obtenir une documentation détaillée incluant cet exemple de code, consultez les articles suivants :
Exemple de code
Sauf indication contraire, le contenu de cette page est régi par une licence Creative Commons Attribution 4.0, et les échantillons de code sont régis par une licence Apache 2.0. Pour en savoir plus, consultez les Règles du site Google Developers. Java est une marque déposée d'Oracle et/ou de ses sociétés affiliées.
[[["Facile à comprendre","easyToUnderstand","thumb-up"],["J'ai pu résoudre mon problème","solvedMyProblem","thumb-up"],["Autre","otherUp","thumb-up"]],[["Difficile à comprendre","hardToUnderstand","thumb-down"],["Informations ou exemple de code incorrects","incorrectInformationOrSampleCode","thumb-down"],["Il n'y a pas l'information/les exemples dont j'ai besoin","missingTheInformationSamplesINeed","thumb-down"],["Problème de traduction","translationIssue","thumb-down"],["Autre","otherDown","thumb-down"]],[],[],[],null,["# Run multiple BigQuery query jobs in parallel\n\nRuns multiple BigQuery query jobs in parallel, demonstrating an improvement in performance when compared to running the jobs serially, one after the other.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [Run multiple BigQuery jobs in parallel](/workflows/docs/tutorials/bigquery-parallel-jobs)\n\nCode sample\n-----------\n\n### YAML\n\n main:\n steps:\n - init:\n assign:\n - results : {} # result from each iteration keyed by table name\n - tables:\n - 201201h\n - 201202h\n - 201203h\n - 201204h\n - 201205h\n - runQueries:\n parallel:\n shared: [results]\n for:\n value: table\n in: ${tables}\n steps:\n - logTable:\n call: sys.log\n args:\n text: ${\"Running query for table \" + table}\n - runQuery:\n call: googleapis.bigquery.v2.jobs.query\n args:\n projectId: ${sys.get_env(\"GOOGLE_CLOUD_PROJECT_ID\")}\n body:\n useLegacySql: false\n useQueryCache: false\n timeoutMs: 30000\n # Find top 100 titles with most views on Wikipedia\n query: ${\n \"SELECT TITLE, SUM(views)\n FROM `bigquery-samples.wikipedia_pageviews.\" + table + \"`\n WHERE LENGTH(TITLE) \u003e 10\n GROUP BY TITLE\n ORDER BY SUM(VIEWS) DESC\n LIMIT 100\"\n }\n result: queryResult\n - returnResult:\n assign:\n # Return the top title from each table\n - results[table]: {}\n - results[table].title: ${queryResult.rows[0].f[0].v}\n - results[table].views: ${queryResult.rows[0].f[1].v}\n - returnResults:\n return: ${results}\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=workflows)."]]