samples: add samples from pubsub/cloud-client #151

This reverts commit e204b86. We want to merge the samples branch *unsquashed* to preserve samples commit history.

Change-Id: I38b90c10aef72c37188c4520897302933b9d2ea7

Change-Id: Ie95e2e1556a8d97b5321dc86bf8de431aa36a2d5

Change-Id: I12c407d3cdf4a3f9736dfaeca6f20b31df6d310a

Change-Id: Ifebdab0b974cc3d3fe8900a23ca7416fed9e026a

…on-docs-samples#540)

…on-docs-samples#542)

…cs-samples#544)

…ython-docs-samples#547)

…amples#569) * Add tests for quickstarts * Update secrets

…oudPlatform/python-docs-samples#599)

GoogleCloudPlatform/python-docs-samples#656)

…on-docs-samples#715)

Change-Id: I7dfe60b0f1240dc58a664968fd97ca5a8fa1109d

…on-docs-samples#825)

…on-docs-samples#876)

…on-docs-samples#922) * Auto-update dependencies. * Fix pubsub iam samples

…cs-samples#962) * Fix README rst links * Update all READMEs

…hon-docs-samples#1004) * Auto-update dependencies. * Fix natural language samples * Fix pubsub iam samples * Fix language samples * Fix bigquery samples

…hon-docs-samples#1055) * Auto-update dependencies. * Explicitly use latest bigtable client Change-Id: Id71e9e768f020730e4ca9514a0d7ebaa794e7d9e * Revert language update for now Change-Id: I8867f154e9a5aae00d0047c9caf880e5e8f50c53 * Remove pdb. smh Change-Id: I5ff905fadc026eebbcd45512d4e76e003e3b2b43

…docs-samples#1092)

Change-Id: I776863091846ee8ff8a70078c8b8d5498cf81ed6

Change-Id: I149fc1242ceb6b2cff8eae7ef18b364dd5c26566

…hon-docs-samples#1097)

…gleCloudPlatform/python-docs-samples#1121) Change-Id: I03b5eaef8b17ac3dc3c0339fd2c7447bd3e11bd2

…orm/python-docs-samples#1158) * Update Readme.rst to add Python setup guide As requested in b/64770713. This sample is linked in documentation https://cloud.google.com/bigtable/docs/scaling, and it would make more sense to update the guide here than in the documentation. * Update README.rst * Update README.rst * Update README.rst * Update README.rst * Update README.rst * Update install_deps.tmpl.rst * Updated readmegen scripts and re-generated related README files * Fixed the lint error

…hon-docs-samples#1138)

Change-Id: I0d420f3053f391fa225e4b8179e45fd1138f5c65

)](GoogleCloudPlatform/python-docs-samples#1169)

…amples#1186)

…amples#1234) * Auto-update dependencies. * Drop pytest-logcapture as it's no longer needed Change-Id: Ia8b9e8aaf248e9770db6bc4842a4532df8383893

…amples#1239)

…loudPlatform/python-docs-samples#1254)

…amples#1263)

…amples#1272) * Auto-update dependencies. * Update requirements.txt

…amples#1282) * Auto-update dependencies. * Fix storage acl sample Change-Id: I413bea899fdde4c4859e4070a9da25845b81f7cf

…cs-samples#1306) * Add listen for errors sample. * Update subscriber.py * Update subscriber.py

…1)](GoogleCloudPlatform/python-docs-samples#1321)

…rm/python-docs-samples#1332) This is a separate PR from actually adding the sample, which is in GoogleCloudPlatform/python-docs-samples#1331.

…thon-docs-samples#1331)

…/python-docs-samples#1335)

…oudPlatform/python-docs-samples#1344) The documentation specifies that the update subscription commands show how to update an endpoint URL: https://cloud.google.com/pubsub/docs/admin#update_a_subscription.

…amples#1359)

…amples#1389)

… [(#1409)](GoogleCloudPlatform/python-docs-samples#1409)

…some samples [(#1441)](GoogleCloudPlatform/python-docs-samples#1441)

…udPlatform/python-docs-samples#1464)

…oogleCloudPlatform/python-docs-samples#1491)

…ocs-samples#1498)

…atform/python-docs-samples#1440) * Add the Pub/Sub handle_publisher_error sample * Update requirements.txt * Update publisher.py * Update publisher.py * Added region tag

…python-docs-samples#1568)

…form/python-docs-samples#1624) * Updated library version * Rewrote test for publish with error handler * Custom _publish function in test prints no 'Attributes'

…-docs-samples#1636)

…amples#1658) * Auto-update dependencies. * Rollback appengine/standard/bigquery/. * Rollback appengine/standard/iap/. * Rollback bigtable/metricscaler. * Rolledback appengine/flexible/datastore. * Rollback dataproc/ * Rollback jobs/api_client * Rollback vision/cloud-client. * Rollback functions/ocr/app. * Rollback iot/api-client/end_to_end_example. * Rollback storage/cloud-client. * Rollback kms/api-client. * Rollback dlp/ * Rollback bigquery/cloud-client. * Rollback iot/api-client/manager. * Rollback appengine/flexible/cloudsql_postgresql.

…CloudPlatform/python-docs-samples#1673) * Added sample for synchronous pull

…es#1680)

…udPlatform/python-docs-samples#1685)

…Platform/python-docs-samples#1701) * Synchronous pull with lease management * Updated library version

…loudPlatform/python-docs-samples#1753) * Moved import stataments inside region tags * Explained topic and subscription path methods

…amples#1800) * Created new end-to-end sample, moved old sample * Add space around operator

…ython-docs-samples#1336) Tests for GoogleCloudPlatform/python-docs-samples#1335. Using ack_deadline_seconds as the example.

…hon-docs-samples#1925) * Fix update test to use new endpoint * Handle subscription already exists Previous deletions don't always succeed * Use a new endpoint for update

…amples#1980) * Auto-update dependencies. * Update requirements.txt * Update requirements.txt

…-samples#2004) * Quickstart V2 * Adopts Kir's suggestions * Adopted Tim's suggestions * proper resource deletion during teardown

…atform/python-docs-samples#2222)

…#2231)

…n-docs-samples#2273) * Publish retry sample * double to single quotes * double to single quotes * license year

…gleCloudPlatform/python-docs-samples#2302)

…python-docs-samples#2078) * Print actual number of messages pulled

…dPlatform/python-docs-samples#2334)

…m/python-docs-samples#2395)

…ples#2403) * print number of messages published * two nit's

…tform/python-docs-samples#2439)

…[(#2475)](GoogleCloudPlatform/python-docs-samples#2475) * update sub.py & requirements.txt * fix flaky subscriber test with separate subscriptions

…ython-docs-samples#2555) * Update test with mock * Clean up resources after tests * Use unique resource names avoid test failures * Delete subscriptions in cleanup phase * Ensure unique topic name * Update assert to remove bytestring notation * Rewrite PubSubToGCS test using dataflow testing module

…oogleCloudPlatform/python-docs-samples#2604) * use result() on streaming pull futures instead of infinite while * remove unused imports

…-docs-samples#2637)

…amples#2005) * Auto-update dependencies. * Revert update of appengine/flexible/datastore. * revert update of appengine/flexible/scipy * revert update of bigquery/bqml * revert update of bigquery/cloud-client * revert update of bigquery/datalab-migration * revert update of bigtable/quickstart * revert update of compute/api * revert update of container_registry/container_analysis * revert update of dataflow/run_template * revert update of datastore/cloud-ndb * revert update of dialogflow/cloud-client * revert update of dlp * revert update of functions/imagemagick * revert update of functions/ocr/app * revert update of healthcare/api-client/fhir * revert update of iam/api-client * revert update of iot/api-client/gcs_file_to_device * revert update of iot/api-client/mqtt_example * revert update of language/automl * revert update of run/image-processing * revert update of vision/automl * revert update testing/requirements.txt * revert update of vision/cloud-client/detect * revert update of vision/cloud-client/product_search * revert update of jobs/v2/api_client * revert update of jobs/v3/api_client * revert update of opencensus * revert update of translate/cloud-client * revert update to speech/cloud-client Co-authored-by: Kurtis Van Gent <31518063+kurtisvg@users.noreply.github.com> Co-authored-by: Doug Mahugh <dmahugh@gmail.com>

…rm/python-docs-samples#2960)

…thon-docs-samples#2986) * remove qs samples * update README

…udPlatform/python-docs-samples#3118) * Add SubscriberClient.close() to examples. Co-authored-by: Prad Nelluru <pradn@google.com> Co-authored-by: Prad Nelluru <prad.nelluru@gmail.com>

…oudPlatform/python-docs-samples#3137) * non-blocking publish * remove unused lib * lint * add defaults

…ples#2806) * chore(deps): update dependency requests to v2.23.0 * Simplify noxfile and add version control. * Configure appengine/standard to only test Python 2.7. * Update Kokokro configs to match noxfile. * Add requirements-test to each folder. * Remove Py2 versions from everything execept appengine/standard. * Remove conftest.py. * Remove appengine/standard/conftest.py * Remove 'no-sucess-flaky-report' from pytest.ini. * Add GAE SDK back to appengine/standard tests. * Fix typo. * Roll pytest to python 2 version. * Add a bunch of testing requirements. * Remove typo. * Add appengine lib directory back in. * Add some additional requirements. * Fix issue with flake8 args. * Even more requirements. * Readd appengine conftest.py. * Add a few more requirements. * Even more Appengine requirements. * Add webtest for appengine/standard/mailgun. * Add some additional requirements. * Add workaround for issue with mailjet-rest. * Add responses for appengine/standard/mailjet. Co-authored-by: Renovate Bot <bot@renovateapp.com>

…eCloudPlatform/python-docs-samples#3470) * [iot] chore: remove unused dependency * [pubsub] chore: remove gcp-devrel-py-tools

…b [(#3343)](GoogleCloudPlatform/python-docs-samples#3343)

…les#3748)

…GoogleCloudPlatform/python-docs-samples#3725) Co-authored-by: Bu Sun Kim <8822365+busunkim96@users.noreply.github.com> Co-authored-by: Takashi Matsuo <tmatsuo@google.com>

…GoogleCloudPlatform/python-docs-samples#3781) Co-authored-by: Bu Sun Kim <8822365+busunkim96@users.noreply.github.com>

…latform/python-docs-samples#3904)

…tform/python-docs-samples#3938) * fix: make timeout an optional positional arg * place `none` back in function signature Co-authored-by: Bu Sun Kim <8822365+busunkim96@users.noreply.github.com>

…thon-docs-samples#3953)

…udPlatform/python-docs-samples#4022)

…latform/python-docs-samples#4027)

…oogleCloudPlatform/python-docs-samples#4070) Use a `with` block to wrap subscriber and describe its purpose. Internal bug: b/157401623

…Platform/python-docs-samples#4039) This PR contains the following updates: | Package | Update | Change | |---|---|---| | [google-cloud-pubsub](https://togithub.com/googleapis/python-pubsub) | minor | `==1.5.0` -> `==1.6.0` | --- ### Release Notes <details> <summary>googleapis/python-pubsub</summary> ### [`v1.6.0`](https://togithub.com/googleapis/python-pubsub/blob/master/CHANGELOG.md#160-httpswwwgithubcomgoogleapispython-pubsubcomparev150v160-2020-06-09) [Compare Source](https://togithub.com/googleapis/python-pubsub/compare/v1.5.0...v1.6.0) ##### Features - Add flow control for message publishing ([#96](https://www.github.com/googleapis/python-pubsub/issues/96)) ([06085c4](https://www.github.com/googleapis/python-pubsub/commit/06085c4083b9dccdd50383257799904510bbf3a0)) ##### Bug Fixes - Fix PubSub incompatibility with api-core 1.17.0+ ([#103](https://www.github.com/googleapis/python-pubsub/issues/103)) ([c02060f](https://www.github.com/googleapis/python-pubsub/commit/c02060fbbe6e2ca4664bee08d2de10665d41dc0b)) ##### Documentation - Clarify that Schedulers shouldn't be used with multiple SubscriberClients ([#100](https://togithub.com/googleapis/python-pubsub/pull/100)) ([cf9e87c](https://togithub.com/googleapis/python-pubsub/commit/cf9e87c80c0771f3fa6ef784a8d76cb760ad37ef)) - Fix update subscription/snapshot/topic samples ([#113](https://togithub.com/googleapis/python-pubsub/pull/113)) ([e62c38b](https://togithub.com/googleapis/python-pubsub/commit/e62c38bb33de2434e32f866979de769382dea34a)) ##### Internal / Testing Changes - Re-generated service implementaton using synth: removed experimental notes from the RetryPolicy and filtering features in anticipation of GA, added DetachSubscription (experimental) ([#114](https://togithub.com/googleapis/python-pubsub/pull/114)) ([0132a46](https://togithub.com/googleapis/python-pubsub/commit/0132a4680e0727ce45d5e27d98ffc9f3541a0962)) - Incorporate will_accept() checks into publish() ([#108](https://togithub.com/googleapis/python-pubsub/pull/108)) ([6c7677e](https://togithub.com/googleapis/python-pubsub/commit/6c7677ecb259672bbb9b6f7646919e602c698570)) </details> --- ### Renovate configuration :date: **Schedule**: At any time (no schedule defined). :vertical_traffic_light: **Automerge**: Disabled by config. Please merge this manually once you are satisfied. :recycle: **Rebasing**: Never, or you tick the rebase/retry checkbox. :no_bell: **Ignore**: Close this PR and you won't be reminded about this update again. --- - [ ] If you want to rebase/retry this PR, check this box --- This PR has been generated by [WhiteSource Renovate](https://renovate.whitesourcesoftware.com). View repository job log [here](https://app.renovatebot.com/dashboard#GoogleCloudPlatform/python-docs-samples).

This restores the chnge from 1cb6746 that got lost during the branch restoration.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

samples: add samples from pubsub/cloud-client #151

samples: add samples from pubsub/cloud-client #151

Commits on Jul 10, 2020