Re: (Golang)HOW TO WRITE BIGQUERY TABLE USING SUSCRIBE TO PUBSUB MESSAGE.THROUGH APACHE BEAM IN GOLANG.

[Abyakta Bal]

*correcting this:-*
*i am using this code: to read from pubsub message*
col := pubsubio.Read(s, project, *input, &pubsubio.ReadOptions{Subscription:
sub.ID()})
*i am using this code:- write in bigquery*
bigqueryio.Write(s, project, *output,*col)*

On Wed, Sep 14, 2022 at 6:39 PM Abyakta Bal <abyakta....@iserveu.in> wrote:

> Dear Team,
> i am trying to write bigquery table using pubsub message pull/suscribe .So
> i am unable to convert *beam.collection []uint8/bytes* to
> *beam.collection* *schema type in go apachebeamsdk.*i am facing this
> issue :-*schema type must be struct: []uint8*
>
> *i am using this code: to read from pubsub message*
> col := pubsubio.Read(s, project, *input, &pubsubio.ReadOptions{
> Subscription: sub.ID()})
> *i am using this code:- write in bigquery*
> bigqueryio.Write(s, project, *output, out)
>
> I request to all please help me to solve this problem.if any clarification
> required please let me know and arrange a call.
>
>
> Thankyou,
> Abyakta bal
>
>