New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Snowflake Avro sync method #123
Conversation
} | ||
|
||
// write this file to snowflake using COPY INTO statement | ||
copyCmd := fmt.Sprintf("COPY INTO %s FROM @%%%s/%s FILE_FORMAT = (TYPE = AVRO)", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚫 [golangci] reported by reviewdog 🐶
G201: SQL string formatting (gosec)
return 0, fmt.Errorf("failed to define Avro schema: %w", err) | ||
} | ||
|
||
fmt.Printf("Avro schema: %s\n", avroSchema) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚫 [golangci] reported by reviewdog 🐶
printf: fmt.Printf format %s has arg avroSchema of wrong type *github.com/PeerDB-io/peer-flow/connectors/snowflake.AvroSchemaDefinition (govet)
// separately based on the specific structure of the data. | ||
// If it's a simple nested structure, you can consider mapping them to "record" types in Avro, similar to | ||
// the bigquery.RecordFieldType case. | ||
return nil, fmt.Errorf("Snowflake semi-structured type %s not supported yet", databaseType) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚫 [golangci] reported by reviewdog 🐶
ST1005: error strings should not be capitalized (stylecheck)
e122a09
to
b354f71
Compare
No description provided.