Skip to content

Commit

Permalink
Merge 6f428cf into 3bd629b
Browse files Browse the repository at this point in the history
  • Loading branch information
roll committed Sep 23, 2020
2 parents 3bd629b + 6f428cf commit 2eb2f7f
Show file tree
Hide file tree
Showing 14 changed files with 539 additions and 259 deletions.
1 change: 1 addition & 0 deletions .gitignore
Expand Up @@ -84,3 +84,4 @@ jsontableschema
datapackage
.mypy_cache
!docs/target
.google.json
Binary file added .google.json.enc
Binary file not shown.
4 changes: 4 additions & 0 deletions .travis.yml
Expand Up @@ -20,8 +20,12 @@ before_install:
- cp .env.example .env
- psql -c 'CREATE DATABASE test;' -U postgres
- mysql -e 'CREATE DATABASE test CHARACTER SET utf8 COLLATE utf8_general_ci;'
- openssl aes-256-cbc -K $encrypted_4885f94bfb6d_key -iv $encrypted_4885f94bfb6d_iv -in .google.json.enc -out .google.json -d

install:
# TODO: remove after
# https://stackoverflow.com/questions/63902467/module-six-moves-has-no-attribute-collections-abc
- pip install 'six>=1.13'
- make install

script:
Expand Down
41 changes: 41 additions & 0 deletions frictionless/package.py
Expand Up @@ -311,6 +311,47 @@ def to_spss(self, *, basepath, force=False):
system.create_storage("spss", basepath=basepath), force=force
)

@staticmethod
def from_bigquery(*, service, project, dataset, prefix=""):
"""Import package from SPSS directory
Parameters:
service (object): BigQuery `Service` object
project (str): BigQuery project name
dataset (str): BigQuery dataset name
prefix? (str): prefix for all names
"""
return Package.from_storage(
system.create_storage(
"bigquery",
service=service,
project=project,
dataset=dataset,
prefix=prefix,
),
)

def to_bigquery(self, *, service, project, dataset, prefix="", force=False):
"""Export package to SPSS directory
Parameters:
service (object): BigQuery `Service` object
project (str): BigQuery project name
dataset (str): BigQuery dataset name
prefix? (str): prefix for all names
force (bool): overwrite existent
"""
return self.to_storage(
system.create_storage(
"bigquery",
service=service,
project=project,
dataset=dataset,
prefix=prefix,
),
force=force,
)

def to_dict(self, expand=False):
"""Convert package to a dict
Expand Down

0 comments on commit 2eb2f7f

Please sign in to comment.