Customer header when going through proxy

[Ian Stansbury]

All,

My company is requiring me to go through a proxy to get to Google PubSub. Setting the url to go to was fairly easy but I have ran into a blocker because I need to add a custom header that the proxy will validate. Anyone have a suggestion on the best approach to adding a customer header before sending the publish call.  Using V1 api.

Thanks,

Ian

[Ian Stansbury]

Also, using the Java util

[Adam]

If you're using the Google API Java Client to call the Pub/Sub API, you can add the custom header using a custom HttpRequestInitializer. An example of how to use a custom HttpRequestInitializer can be found in the client library documentation section Handling Errors. In this case it shows how to set a retry handler, but it can be trivially modified to also add custom headers by adding a call to request.setHeaders(). Another, more complete example of  HttpRequestInitializer can be found in RetryHttpInitializerWrapper in the cloud-pubsub-samples-java GitHub repository.

[Santosh Ashtaputra]

Hi Adam,

Could you tell me how to connect to pubsub through proxy for python client. i'm using below sample code for getting monitoring data from pubsub.

from oauth2client.contrib.gce import AppAssertionCredentials

from oauth2client.service_account import ServiceAccountCredentials

from httplib2 import Http

from apiclient.discovery import build

credentials = AppAssertionCredentials('https://www.googleapis.com/auth/pubsub')

scopes = ['https://www.googleapis.com/auth/pubsub', ' https://www.googleapis.com/auth/cloud-platform','https://www.googleapis.com/auth/monitoring', 'https://www.googleapis.com/auth/monitoring.write' ,'https://www.googleapis.com/auth/cloud-platform' , 'https://www.googleapis.com/auth/monitoring.read']

credentials = ServiceAccountCredentials.from_json_keyfile_name('path to json file', scopes=scopes)

http_auth = credentials.authorize(Http())

pubsub1 = build('pubsub', 'v1',http=http_auth)

[Santosh Ashtaputra]

It worked by using below command:

http_auth = credentials.authorize(Http(proxy_info = httplib2.ProxyInfo(httplib2.socks.PROXY_TYPE_HTTP_NO_TUNNEL, 'proxy url wihout http', 8080, proxy_user = '', proxy_pass = '') ))