salgo60/checkWikidata_P1260_RAÄ.py

## checkWikidata_P1260_RAÄ.py
# See question RAÄ FB https://www.facebook.com/riksantikvarieambetet/posts/10158191730201970
# pip install sparqlwrapper
# https://rdflib.github.io/sparqlwrapper/
# this https://gist.github.com/salgo60/49c52e1f7009f0ef318e9fadd94addc5
# old https://gist.github.com/salgo60/a4ebde4f0a279d5f9479aeaf7b846403
#
# "Problemet med Persistenta identifierare och hävda att http status koder fungerar"
# https://github.com/salgo60/SamlaLibris/issues/12
#
# Försök med bättre felsida https://github.com/riksantikvarieambetet/ksamsok/pull/1#issuecomment-752963121
#
from datetime import datetime
import urllib3
import sys
from SPARQLWrapper import SPARQLWrapper, JSON

endpoint_url = "https://query.wikidata.org/sparql"
http = urllib3.PoolManager()

# Check linkroot
# SPARQL used https://w.wiki/7Qmp 20230907 173031
query = """SELECT ?wd ?wdLabel  ?Ksam ?oldURL WHERE {
  ?wd wdt:P1260 ?Ksam
  BIND (URI(CONCAT("http://kulturarvsdata.se/",?Ksam)) AS ?oldURL)
SERVICE wikibase:label { bd:serviceParam wikibase:language "sv,en". }
} limit 200000
"""


def get_results(endpoint_url, query):
    user_agent = "user:salgo60/%s.%s" % (sys.version_info[0], sys.version_info[1])
    sparql = SPARQLWrapper(endpoint_url, agent=user_agent)
    sparql.setQuery(query)
    sparql.setReturnFormat(JSON)
    return sparql.query().convert()

''' Check if URLS is ok'''
def check(url,wd, wdLabel):
    try:
        r = http.request('GET', url)
    except Exception as e:
        print("\t\tError\t",str(e))
        return False
    if r.status != 200:
            print("Status: ",r.status, " \t", url, "\tWikidata: ", wd," - ", wdLabel)
            return False
    return True
start_time  = datetime.now()
print("Last run: ", start_time)
results = get_results(endpoint_url, query)
print ("Number records i Wikidata: " + str(len(results["results"]["bindings"])))

ok = 0
notok = 0
for result in results["results"]["bindings"]:
    #print(result)
    currentURL = result["oldURL"]["value"]
    wd = result["wd"]["value"]
    wdLabel = result["wdLabel"]["value"]
    if check(currentURL,wd, wdLabel):
        ok += 1
    else:
        notok += 1
print("OK: ",ok,"\t not ok",notok)
end = datetime.now()
print("Ended: ", end)
print('Time elapsed (hh:mm:ss.ms) {}'.format(datetime.now() - start_time))
	# See question RAÄ FB https://www.facebook.com/riksantikvarieambetet/posts/10158191730201970
	# pip install sparqlwrapper
	# https://rdflib.github.io/sparqlwrapper/
	# this https://gist.github.com/salgo60/49c52e1f7009f0ef318e9fadd94addc5
	# old https://gist.github.com/salgo60/a4ebde4f0a279d5f9479aeaf7b846403
	#
	# "Problemet med Persistenta identifierare och hävda att http status koder fungerar"
	# https://github.com/salgo60/SamlaLibris/issues/12
	#
	# Försök med bättre felsida https://github.com/riksantikvarieambetet/ksamsok/pull/1#issuecomment-752963121
	#
	from datetime import datetime
	import urllib3
	import sys
	from SPARQLWrapper import SPARQLWrapper, JSON

	endpoint_url = "https://query.wikidata.org/sparql"
	http = urllib3.PoolManager()

	# Check linkroot
	# SPARQL used https://w.wiki/7Qmp 20230907 173031
	query = """SELECT ?wd ?wdLabel ?Ksam ?oldURL WHERE {
	?wd wdt:P1260 ?Ksam
	BIND (URI(CONCAT("http://kulturarvsdata.se/",?Ksam)) AS ?oldURL)
	SERVICE wikibase:label { bd:serviceParam wikibase:language "sv,en". }
	} limit 200000
	"""


	def get_results(endpoint_url, query):
	user_agent = "user:salgo60/%s.%s" % (sys.version_info[0], sys.version_info[1])
	sparql = SPARQLWrapper(endpoint_url, agent=user_agent)
	sparql.setQuery(query)
	sparql.setReturnFormat(JSON)
	return sparql.query().convert()

	''' Check if URLS is ok'''
	def check(url,wd, wdLabel):
	try:
	r = http.request('GET', url)
	except Exception as e:
	print("\t\tError\t",str(e))
	return False
	if r.status != 200:
	print("Status: ",r.status, " \t", url, "\tWikidata: ", wd," - ", wdLabel)
	return False
	return True
	start_time = datetime.now()
	print("Last run: ", start_time)
	results = get_results(endpoint_url, query)
	print ("Number records i Wikidata: " + str(len(results["results"]["bindings"])))

	ok = 0
	notok = 0
	for result in results["results"]["bindings"]:
	#print(result)
	currentURL = result["oldURL"]["value"]
	wd = result["wd"]["value"]
	wdLabel = result["wdLabel"]["value"]
	if check(currentURL,wd, wdLabel):
	ok += 1
	else:
	notok += 1
	print("OK: ",ok,"\t not ok",notok)
	end = datetime.now()
	print("Ended: ", end)
	print('Time elapsed (hh:mm:ss.ms) {}'.format(datetime.now() - start_time))