Multiple Destination Support for Go and Python Turbine streaming apps

Turbine-go and Turbine-py now have support for multiple destination resources for use in your Turbine streaming apps.

Multiple destination resources can be added to a Turbine Data Application in the same way you would add a singular destination. For example:

in Go:

    dest, err := v.Resources("dest-one")
	if err != nil {
		return err
	}

    dest2, err := v.Resources("dest-two")
	if err != nil {
		return err
	}

	err = dest.Write(res, "dest-one")
	if err != nil {
		return err
	}

    err = dest.Write(res, "dest-two")
	if err != nil {
		return err
	}

and in Python:

    destination_one = await turbine.resources("dest-one")
    destination_two = await turbine.resources("dest-two")

    await destination_one.write(records, "collection_archive", {})
    await destination_two.write(records, "collection_archive_two", {})

Both destinations will show up as destination resources on both your Dashboard and in the Meroxa CLI.

For any questions or comments, please feel free to email us at [email protected] or reach out to us on Twitter or on Discord.

Tweet