timhberry

from google.cloud import bigquery

client = bigquery.Client()

# returns a Query Job object
# https://googleapis.dev/python/bigquery/latest/generated/google.cloud.bigquery.job.QueryJob.html#google.cloud.bigquery.job.QueryJob

query = client.query(
    """
    SELECT * FROM ...

timhberry

import logging
import json
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions, StandardOptions

# pub/sub subscription in the format: projects/<your-project>/subscriptions/<subscription-name>
sub = ''

# bigquery table in the format: project:dataset.table

timhberry

from datetime import datetime
import logging
import random

from apache_beam import DoFn, GroupByKey, io, ParDo, Pipeline, PTransform, WindowInto, WithKeys
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.transforms.window import FixedWindows

# your pub/sub topic, format: projects/<your-project-name>/topics/<your-topic-name>
input_topic = ''

timhberry

import re
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions

# Input and output files should be Cloud Storage locations
# beginning with gs://
input_file = 'gs://<your-bucket-name>/kinglear.txt'
output_path = 'gs://<your-bucket-name>/counts.txt'

# Replace <your-bucket-name>, <your-project-name> and <your-sa-email>

timhberry

from google.cloud import bigquery

dataset = "btlearningpath"
table = "city_speeds_from_function"

def add_to_bq(data, context):

    source_bucket = data['bucket']
    source_file = data['name']
    uri = 'gs://{}/{}'.format(source_bucket, source_file)

timhberry

### BigQuery schema

country:STRING,
country_code:STRING,
region:STRING,
region_code:STRING,
city:STRING,
date:DATE,
download_kbps:FLOAT,
upload_kbps:FLOAT,

timhberry

import csv
from google.cloud import bigquery
from time import sleep
from random import random

client = bigquery.Client()

table_id = "ab-academy-demo.btlearningpath.city_speeds_bq_stream"
filename = "city_daily_speeds-10k.csv"

timhberry

import csv
import json
from concurrent import futures
from google.cloud import pubsub_v1
from typing import Callable
from time import sleep
from random import random


project_id = "ab-academy-demo"

timhberry

$('textarea').keyup(function() {
    
    var characterCount = $(this).val().length,
        current = $('#current'),
        maximum = $('#maximum'),
        theCount = $('#the-count');
      
    current.text(characterCount);
   
    

timhberry

<?php

// called by every page that should only be showed to a logged in user
// will ensure a valud session exists either in the local session cache
// or via a session key stored in a cookie which can be retrieved
// from the sessions table in the database

// first check for existing session ID
session_start();