A mapping-based pipeline for creating a phylogeny from bacterial whole genome sequences
Introduction
nf-core/bactmap is a bioinformatics best-practice analysis pipeline for mapping short reads from bacterial WGS to a reference sequence, creating filtered VCF files, making pseudogenomes based on high quality positions in the VCF files and optionally creating a phylogeny from an alignment of the pseudogenomes.
The pipeline is built using Nextflow , a workflow tool to run tasks across multiple compute infrastructures in a very portable manner. It uses Docker/Singularity containers making installation trivial and results highly reproducible. The Nextflow DSL2 implementation of this pipeline uses one container per process which makes it much easier to maintain and update software dependencies. Where possible, these processes have been submitted to and installed from nf-core/modules in order to make them available to all nf-core pipelines, and to everyone within the Nextflow community!
On release, automated continuous integration tests run the pipeline on a full-sized dataset on the AWS cloud infrastructure. This ensures that the pipeline runs on AWS, has sensible resource allocation defaults set to run on real-world datasets, and permits the persistent storage of results to benchmark between pipeline releases and other analysis sources. The results obtained from the full-sized test can be viewed on the nf-core website .
Pipeline summary
The pipeline is composed of the following steps:
-
Index reference fasta file (
BWA index
) -
Trim reads for quality and adapter sequence (Optional) (
fastp
) -
Estimate genome size (
mash sketch
) -
Downsample fastq files (Optional) (
Rasusa
) -
Variant calling
-
Read mapping (
BWA mem
) -
Sort and index alignments (
SAMtools
) -
Call and filter variants (
BCFtools
) -
Convert filtered bcf to pseudogenome fasta (
vcf2pseudogenome.py
)
-
-
Create alignment from pseudogenome by concatenating fasta files having first checked that the sample sequences are high quality(
calculate_fraction_of_non_GATC_bases.py
) -
Remove recombination (Optional) (
Gubbins
) -
Extract variant sites from alignment (
SNP-sites
) -
Construct phylogenetic tree (Optional)
Quick Start
-
Install
Nextflow
(>=21.04.0
) -
Install any of
Docker
,Singularity
,Podman
,Shifter
orCharliecloud
for full pipeline reproducibility (please only useConda
as a last resort; see docs ) -
Download the pipeline and test it on a minimal dataset with a single command:
nextflow run nf-core/bactmap -profile test,<docker/singularity/podman/shifter/charliecloud/conda/institute>
-
Please check nf-core/configs to see if a custom config file to run nf-core pipelines already exists for your Institute. If so, you can simply use
-profile <institute>
in your command. This will enable eitherdocker
orsingularity
and set the appropriate execution settings for your local compute environment. -
If you are using
singularity
then the pipeline will auto-detect this and attempt to download the Singularity images directly as opposed to performing a conversion from Docker images. If you are persistently observing issues downloading Singularity images directly due to timeout or network issues then please use the--singularity_pull_docker_container
parameter to pull and convert the Docker image instead. Alternatively, it is highly recommended to use thenf-core download
command to pre-download all of the required containers before running the pipeline and to set theNXF_SINGULARITY_CACHEDIR
orsingularity.cacheDir
Nextflow options to be able to store and re-use the images from a central location for future pipeline runs. -
If you are using
conda
, it is highly recommended to use theNXF_CONDA_CACHEDIR
orconda.cacheDir
settings to store the environments in a central location for future pipeline runs.
-
-
Start running your own analysis!
nextflow run nf-core/bactmap -profile <docker/singularity/podman/conda/institute> --input samplesheet.csv --reference chromosome.fasta
Documentation
The nf-core/bactmap pipeline comes with documentation about the pipeline usage , parameters and output .
Credits
nf-core/bactmap was originally written by Anthony Underwood , Andries van Tonder and Thanh Le Viet .
We thank the following people for their extensive assistance in the development of this pipeline:
Anthony Underwood's time working on the project was funded by the National Institute for Health Research
(NIHR) Global Health Research Unit for the Surveillance of Antimicrobial Resistance (Grant Reference Number 16/136/111)
Contributions and Support
If you would like to contribute to this pipeline, please see the contributing guidelines .
For further information or help, don't hesitate to get in touch on the
Slack
#bactmap
channel
(you can join with
this invite
).
Citations
An extensive list of references for the tools used by the pipeline can be found in the
CITATIONS.md
file.
You can cite the
nf-core
publication as follows:
The nf-core framework for community-curated bioinformatics pipelines.
Philip Ewels, Alexander Peltzer, Sven Fillinger, Harshil Patel, Johannes Alneberg, Andreas Wilm, Maxime Ulysse Garcia, Paolo Di Tommaso & Sven Nahnsen.
Nat Biotechnol. 2020 Feb 13. doi: 10.1038/s41587-020-0439-x .
Code Snippets
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 | """ touch low_quality_pseudogenomes.tsv touch aligned_pseudogenomes.fas for pseudogenome in ${pseudogenomes} do fraction_non_GATC_bases=\$(calculate_fraction_of_non_GATC_bases.py -f \$pseudogenome | tr -d '\\n') if awk 'BEGIN { exit !(\$fraction_non_GATC_bases < ${params.non_GATC_threshold}) }'; then cat \$pseudogenome >> aligned_pseudogenomes.fas else echo "\$pseudogenome\t\$fraction_non_GATC_bases" >> low_quality_pseudogenomes.tsv fi done reference2single_sequence.py -r ${reference} -o final_reference.fas cat final_reference.fas >> aligned_pseudogenomes.fas NUM_ALIGNMENT_GENOMES=\$(grep -c ">" aligned_pseudogenomes.fas) """ |
27 28 29 30 31 | """ echo $workflow.manifest.version > pipeline.version.txt echo $workflow.nextflow.version > nextflow.version.txt scrape_software_versions.py &> software_versions_mqc.yaml """ |
39 40 41 42 | """ multiqc -f $options.args $custom_config . multiqc --version | sed -e "s/multiqc, version //g" > ${software}.version.txt """ |
26 27 28 | """ check_samplesheet.py $samplesheet samplesheet.valid.csv """ |
30 31 32 | """ vcf2pseudogenome.py -r ${reference} -b ${vcf} -o ${meta.id}.fas """ |
31 32 33 34 35 36 37 38 | """ bcftools filter \\ --output ${prefix}.vcf.gz \\ $options.args \\ $vcf echo \$(bcftools --version 2>&1) | sed 's/^.*bcftools //; s/ .*\$//' > ${software}.version.txt """ |
34 35 36 37 38 39 40 41 42 43 44 45 46 | """ echo "${meta.id}" > sample_name.list bcftools mpileup \\ --fasta-ref $fasta \\ $options.args \\ $bam \\ | bcftools call --output-type v $options.args2 \\ | bcftools reheader --samples sample_name.list \\ | bcftools view --output-file ${prefix}.vcf.gz --output-type z $options.args3 tabix -p vcf -f ${prefix}.vcf.gz bcftools stats ${prefix}.vcf.gz > ${prefix}.bcftools_stats.txt echo \$(bcftools --version 2>&1) | sed 's/^.*bcftools //; s/ .*\$//' > ${software}.version.txt """ |
30 31 32 33 34 | """ mkdir index bwa index $options.args -p index/${fasta.baseName} $fasta echo \$(bwa 2>&1) | sed 's/^.*Version: //; s/Contact:.*\$//' > ${software}.version.txt """ |
33 34 35 36 37 38 39 40 41 42 43 44 45 | """ INDEX=`find -L ./ -name "*.amb" | sed 's/.amb//'` bwa mem \\ $options.args \\ $read_group \\ -t $task.cpus \\ \$INDEX \\ $reads \\ | samtools view $options.args2 -@ $task.cpus -bhS -o ${prefix}.bam - echo \$(bwa 2>&1) | sed 's/^.*Version: //; s/Contact:.*\$//' > ${software}.version.txt """ |
39 40 41 42 43 44 45 46 47 48 49 50 51 | """ [ ! -f ${prefix}.fastq.gz ] && ln -s $reads ${prefix}.fastq.gz fastp \\ --in1 ${prefix}.fastq.gz \\ --out1 ${prefix}.trim.fastq.gz \\ --thread $task.cpus \\ --json ${prefix}.fastp.json \\ --html ${prefix}.fastp.html \\ $fail_fastq \\ $options.args \\ 2> ${prefix}.fastp.log echo \$(fastp --version 2>&1) | sed -e "s/fastp //g" > ${software}.version.txt """ |
54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 | """ [ ! -f ${prefix}_1.fastq.gz ] && ln -s ${reads[0]} ${prefix}_1.fastq.gz [ ! -f ${prefix}_2.fastq.gz ] && ln -s ${reads[1]} ${prefix}_2.fastq.gz fastp \\ --in1 ${prefix}_1.fastq.gz \\ --in2 ${prefix}_2.fastq.gz \\ --out1 ${prefix}_1.trim.fastq.gz \\ --out2 ${prefix}_2.trim.fastq.gz \\ --json ${prefix}.fastp.json \\ --html ${prefix}.fastp.html \\ $fail_fastq \\ --thread $task.cpus \\ --detect_adapter_for_pe \\ $options.args \\ 2> ${prefix}.fastp.log echo \$(fastp --version 2>&1) | sed -e "s/fastp //g" > ${software}.version.txt """ |
30 31 32 33 34 35 36 37 38 | """ fasttree \\ $options.args \\ -log fasttree_phylogeny.tre.log \\ -nt $alignment \\ > fasttree_phylogeny.tre echo \$(fasttree -help 2>&1) | head -1 | sed 's/^FastTree \\([0-9\\.]*\\) .*\$/\\1/' > ${software}.version.txt """ |
37 38 39 40 41 42 43 | """ run_gubbins.py \\ --threads $task.cpus \\ $options.args \\ $alignment echo \$(run_gubbins.py --version 2>&1) > ${software}.version.txt """ |
32 33 34 35 36 37 38 39 40 41 42 | """ iqtree \\ $fconst_args \\ $options.args \\ -s $alignment \\ -nt AUTO \\ -ntmax $task.cpus \\ -mem $memory \\ echo \$(iqtree -version 2>&1) | sed 's/^IQ-TREE multicore version \\([0-9\\.]*\\) .*\$/\\1/' > ${software}.version.txt """ |
30 31 32 33 34 35 36 37 38 39 | """ mash \\ sketch \\ $options.args \\ -p $task.cpus \\ -o ${prefix} \\ -r $reads \\ 2> ${prefix}.mash_stats echo \$(mash --version 2>&1) > ${software}.version.txt """ |
31 32 33 34 35 36 37 38 39 40 41 42 43 44 | """ python \\ -c 'from Bio import SeqIO; SeqIO.convert("$alignment", "fasta", "alignment.sth", "stockholm")' rapidnj \\ alignment.sth \\ $options.args \\ -i sth \\ -c $task.cpus \\ -x rapidnj_phylogeny.tre # Doesn't appear to be a way of getting the version number echo 2.3.2 > ${software}.version.txt """ |
33 34 35 36 37 38 39 40 41 | """ rasusa \\ $options.args \\ --coverage $depth_cutoff \\ --genome-size $genome_size \\ --input $reads \\ $output echo \$(rasusa --version 2>&1) | sed -e "s/rasusa //g" > ${software}.version.txt """ |
31 32 33 34 35 36 37 38 39 | """ raxml-ng \\ $options.args \\ --msa $alignment \\ --threads $task.cpus \\ --prefix output echo \$(raxml-ng --version 2>&1) | sed 's/^.*RAxML-NG v. //; s/released.*\$//' > ${software}.version.txt """ |
30 31 32 33 | """ samtools flagstat $bam > ${bam}.flagstat echo \$(samtools --version 2>&1) | sed 's/^.*samtools //; s/Using.*\$//' > ${software}.version.txt """ |
30 31 32 33 | """ samtools idxstats $bam > ${bam}.idxstats echo \$(samtools --version 2>&1) | sed 's/^.*samtools //; s/Using.*\$//' > ${software}.version.txt """ |
30 31 32 33 | """ samtools index $bam echo \$(samtools --version 2>&1) | sed 's/^.*samtools //; s/Using.*\$//' > ${software}.version.txt """ |
31 32 33 34 | """ samtools sort $options.args -@ $task.cpus -o ${prefix}.bam -T $prefix $bam echo \$(samtools --version 2>&1) | sed 's/^.*samtools //; s/Using.*\$//' > ${software}.version.txt """ |
30 31 32 33 | """ samtools stats $bam > ${bam}.stats echo \$(samtools --version 2>&1) | sed 's/^.*samtools //; s/Using.*\$//' > ${software}.version.txt """ |
31 32 33 34 35 36 37 38 39 40 41 | """ snp-sites \\ $alignment \\ > filtered_alignment.fas echo \$(snp-sites -C $alignment) > constant.sites.txt CONSTANT_SITES=\$(cat constant.sites.txt) echo \$(snp-sites -V 2>&1) | sed 's/snp-sites //' > ${software}.version.txt """ |
Support
- Future updates
Related Workflows





