You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
11 KiB
11 KiB
<html>
<head>
</head>
</html>
In [ ]:
pip install gql
In [2]:
!jupyter labextension install jupyterlab-tailwind-theme
Building jupyterlab assets (production, minimized) An error occurred. PermissionError: [Errno 1] Operation not permitted: '/opt/conda/share/jupyter/lab/staging/index.js' See the log file for details: /tmp/jupyterlab-debug-dk1kbsy9.log
In [ ]:
import json
import os
import pprint
import requests
from gql import Client, gql
from gql.transport.requests import RequestsHTTPTransport
cwd = os.getcwd()
print(cwd)
In [14]:
data_json = os.env(PATH)
with open(data_json) as f:
scrubbed_records = json.load(f)
# print(scrubbed_records[0])
item = scrubbed_records[0]
name = item["Name"]
image = item["Config"]["Image"]
# print(name)
# print(image)
image = image.replace(":latest", "")
name = name.replace("/", "")
print(name)
print(image)
active_workflow automaticmode/active_workflow
In [ ]:
for x in scrubbed_records:
# pprint.pprint(x)
image = image.replace(":latest", "")
name = name.replace("/", "")
data = x
In [ ]:
for x in scrubbed_records:
# pprint.pprint(x)
item = x
name = item["Name"]
image = item["Config"]["Image"]
image = image.replace(":latest", "")
name = name.replace("/", "")
print(name)
print(image)
input_set = {"id": name, "image": image, "name": name, "raw": item}
my_headers = {"Authorization": "os.env(directus_token)", "Content-Type": "application/json"}
response = requests.post(
"https://cms.donavanaldrich.com/items/containers",
headers=my_headers,
json=(input_set),
)
print(response.json())
In [ ]:
pip install gql[all] aiohttp
In [28]:
sample_transport = RequestsHTTPTransport(
url="http://directus:8055/graphql",
use_json=True,
headers={
"Content-type": "application/json",
"Authorization": "os.env(directus_token)",
},
verify=True,
retries=3,
)
client = Client(
transport=sample_transport,
fetch_schema_from_transport=True,
)
query = gql(
'''
query {
pages {
single(id: 3) {
id
path
locale
title
description
contentType
isPublished
isPrivate
privateNS
createdAt
updatedAt
}
}
}
'''
)
# params = { "title": article_attributes_data-posted-on }
result = client.execute(query, variable_values=params)
--------------------------------------------------------------------------- NameError Traceback (most recent call last) /tmp/ipykernel_7244/3689489481.py in <cell line: 1>() ----> 1 sample_transport = RequestsHTTPTransport( 2 url="http://directus:8055/graphql", 3 use_json=True, 4 headers={ 5 "Content-type": "application/json", NameError: name 'RequestsHTTPTransport' is not defined
In [ ]:
import asyncio
from gql import gql, Client
from gql.transport.aiohttp import AIOHTTPTransport
transport = AIOHTTPTransport(
url="http://wiki:3000/graphql",
headers={
"Content-type": "application/json",
"Authorization": "os.env(directus_token)",
},
)
# Create a GraphQL client using the defined transport
# client = Client(transport=transport, fetch_schema_from_transport=True)
client = Client(transport=transport, fetch_schema_from_transport=False)
# client = Client(transport=transport, fetch_schema_from_transport=True)
query = gql(
'''
query pageList {
pages {
list(locale: "en") {
id
path
locale
title
description
contentType
isPublished
isPrivate
privateNS
createdAt
updatedAt
tags
}
}
}
'''
)
# result = await session.execute(query)
# print(result)
result = await client.execute_async(query)
print(result)
# asyncio.run(main())
# Execute the query on the transport
# result = await client.execute_async(query)
# print(result)
In [ ]:
from gql import gql, Client
from gql.transport.aiohttp import AIOHTTPTransport
# Select your transport with a defined url endpoint
transport = AIOHTTPTransport(url="https://countries.trevorblades.com/")
# Create a GraphQL client using the defined transport
client = Client(transport=transport, fetch_schema_from_transport=True)
# Provide a GraphQL query
query = gql(
"""
query getContinents {
continents {
code
name
}
}
"""
)
# Execute the query on the transport
result = client.execute(query)
print(result)