Title: Python to construct CASE WHEN update SQL statement · Issue #970 · googleapis/python-bigquery · GitHub
Open Graph Title: Python to construct CASE WHEN update SQL statement · Issue #970 · googleapis/python-bigquery
X Title: Python to construct CASE WHEN update SQL statement · Issue #970 · googleapis/python-bigquery
Description: I try to update 2K rows in BQ def update_bq_ads_status_failed(self, update_ads): affected_rows = 0 for update_ads_chunk in split(update_ads, _UPDATE_CHUNK_SIZE): ad_ids = [item["ad_id"] for item in update_ads_chunk] removal_errors = [ite...
Open Graph Description: I try to update 2K rows in BQ def update_bq_ads_status_failed(self, update_ads): affected_rows = 0 for update_ads_chunk in split(update_ads, _UPDATE_CHUNK_SIZE): ad_ids = [item["ad_id"] for item in...
X Description: I try to update 2K rows in BQ def update_bq_ads_status_failed(self, update_ads): affected_rows = 0 for update_ads_chunk in split(update_ads, _UPDATE_CHUNK_SIZE): ad_ids = [item["ad_id"] f...
Opengraph URL: https://github.com/googleapis/python-bigquery/issues/970
X: @github
Domain: github.com
{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Python to construct CASE WHEN update SQL statement","articleBody":"I try to update 2K rows in BQ \r\n\r\n\r\n\r\n\r\n```\r\ndef update_bq_ads_status_failed(self, update_ads):\r\n affected_rows = 0\r\n for update_ads_chunk in split(update_ads, _UPDATE_CHUNK_SIZE):\r\n ad_ids = [item[\"ad_id\"] for item in update_ads_chunk]\r\n removal_errors = [item[\"removal_error\"] for item in update_ads_chunk]\r\n\r\n update_removal_error = \"\"\r\n for ad_id, removal_error in zip(ad_ids, removal_errors):\r\n update_removal_error = update_removal_error + \\\r\n f''' WHEN ad_id = '{ad_id}' Then '{removal_error}' '''\r\n affected_rows += self.update_bq_ads_status(f\"\"\"\r\n UPDATE '{table_full_name}' \r\n SET status = 'Failed Removing' \r\n SET removal_error = CASE {update_removal_error} END \r\n WHERE ad_id IN {str(ad_ids)}\r\n \"\"\")\r\n return affected_rows\r\n```\r\n\r\n\r\nI'm getting this error. I know it's too vague and not possible to debug like this.\r\n\r\n\u003e timeout=300.0, headers={'X-Server-Timeout': '300.0',\r\n\u003e 'Accept-Encoding': 'gzip', 'Content-Type': 'application/json',\r\n\u003e 'X-Goog-API-Client': 'gl-python/3.8.10 grpc/1.39.0 gax/2.0.0\r\n\u003e gapic/2.26.0 gccl/2.26.0', 'User-Agent': 'gl-python/3.8.10 grpc/1.39.0\r\n\u003e gax/2.0.0 gapic/2.26.0 gccl/2.26.0'})), last exception: ('Connection\r\n\u003e aborted.', RemoteDisconnected('Remote end closed connection without\r\n\u003e response'))\r\n\r\n\r\nI'm trying to eliminate errors. Is my BQ update syntactically correct? \r\n\r\nWhat's the BQ update timeout?","author":{"url":"https://github.com/elad2109","@type":"Person","name":"elad2109"},"datePublished":"2021-09-14T00:26:49.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":5},"url":"https://github.com/970/python-bigquery/issues/970"}
| route-pattern | /_view_fragments/issues/show/:user_id/:repository/:id/issue_layout(.:format) |
| route-controller | voltron_issues_fragments |
| route-action | issue_layout |
| fetch-nonce | v2:ba588606-0345-6d46-bf92-6b0b181a1198 |
| current-catalog-service-hash | 81bb79d38c15960b92d99bca9288a9108c7a47b18f2423d0f6438c5b7bcd2114 |
| request-id | D7D4:25C9D0:DC6802:12C6E60:6A4DCEE6 |
| html-safe-nonce | a6d5dc979a10da4e987dc756596e5d59013a7545fa5ad851e0409750451290ad |
| visitor-payload | eyJyZWZlcnJlciI6IiIsInJlcXVlc3RfaWQiOiJEN0Q0OjI1QzlEMDpEQzY4MDI6MTJDNkU2MDo2QTREQ0VFNiIsInZpc2l0b3JfaWQiOiI2NTgyMzc0NzIyNTE5ODEzODYyIiwicmVnaW9uX2VkZ2UiOiJpYWQiLCJyZWdpb25fcmVuZGVyIjoiaWFkIn0= |
| visitor-hmac | e363658a38f0fbd905b9b3e4508d58c867012ff56f07b3b60589ff6cd4ca5cbf |
| hovercard-subject-tag | issue:996107850 |
| github-keyboard-shortcuts | repository,issues,copilot |
| google-site-verification | Apib7-x98H0j5cPqHWwSMm6dNU4GmODRoqxLiDzdx9I |
| octolytics-url | https://collector.github.com/github/collect |
| analytics-location | / |
| fb:app_id | 1401488693436528 |
| apple-itunes-app | app-id=1477376905, app-argument=https://github.com/_view_fragments/issues/show/googleapis/python-bigquery/970/issue_layout |
| twitter:image | https://opengraph.githubassets.com/ae5728de9283822d96e87a0b1d9e194f212abdeedf8f725a09e6a140bd7f36b0/googleapis/python-bigquery/issues/970 |
| twitter:card | summary_large_image |
| og:image | https://opengraph.githubassets.com/ae5728de9283822d96e87a0b1d9e194f212abdeedf8f725a09e6a140bd7f36b0/googleapis/python-bigquery/issues/970 |
| og:image:alt | I try to update 2K rows in BQ def update_bq_ads_status_failed(self, update_ads): affected_rows = 0 for update_ads_chunk in split(update_ads, _UPDATE_CHUNK_SIZE): ad_ids = [item["ad_id"] for item in... |
| og:image:width | 1200 |
| og:image:height | 600 |
| og:site_name | GitHub |
| og:type | object |
| og:author:username | elad2109 |
| hostname | github.com |
| expected-hostname | github.com |
| None | 06b8a6144231bf3a234f1c2e9993861e07ce98a905912b114aa386c2d7e84b33 |
| turbo-cache-control | no-preview |
| go-import | github.com/googleapis/python-bigquery git https://github.com/googleapis/python-bigquery.git |
| octolytics-dimension-user_id | 16785467 |
| octolytics-dimension-user_login | googleapis |
| octolytics-dimension-repository_id | 226992475 |
| octolytics-dimension-repository_nwo | googleapis/python-bigquery |
| octolytics-dimension-repository_public | true |
| octolytics-dimension-repository_is_fork | false |
| octolytics-dimension-repository_network_root_id | 226992475 |
| octolytics-dimension-repository_network_root_nwo | googleapis/python-bigquery |
| turbo-body-classes | logged-out env-production page-responsive |
| disable-turbo | false |
| browser-stats-url | https://api.github.com/_private/browser/stats |
| browser-errors-url | https://api.github.com/_private/browser/errors |
| release | 1d344bdb7547fe6bca17a59bb2b8aac3dc9532a0 |
| ui-target | full |
| theme-color | #1e2327 |
| color-scheme | light dark |
Links:
Viewport: width=device-width